我有一个包含 WebSocket 的主题（https://github.com/Reactive-Extensions/RxJS-DOM/blob/master/doc/operators/fromwebsocket.md），我想缓冲 WebSocket 接收到的消息。我查看了https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/buffer.md但使用了 observable 而不是主题。此外，我读过主题可用于使用缓冲或缓存“您可以使用主题来实现具有缓存、缓冲和时移的自定义 observable”（https://xgrommx.github.io/rx-book/content /getting_started_with_rxjs/subjects.html），我如何使用主题和观察者来实现这类事情（缓冲，缓存，......）。
我对 Rx 的概念有点迷茫，它们比 akka-streams 更难！！
谢谢，