Summary

In this chapter, we implemented a real-world example of consuming real-time messages coming from a WebSocket server in a reactive way. We explained the requirements and the context. Then we explored the features of WebSocketSubject and learned how we can consume real-time messages through the WebSocketSubject and how this special kind of subject works. Finally, we learned how we can build a reconnection mechanism in a reactive way using WebSocketSubjectConfig and the RxJS operators.

The following are some of the key concepts discussed in this chapter:

• We learned that RxJS offers WebSocketSubject, a specialized subject for WebSocket communication, allowing both data transmission and reception through WebSocket connections. By using the webSocket factory function, you can easily create and manage WebSocket connections in your applications with similar API methods as regular subjects for listening, sending, handling errors, and closing connections.