a little details here: socket creation: ``` httpC...
# arrow
a little details here: socket creation:
Copy code
httpClient.newWebSocket(request, object : WebSocketListener() {
	override fun onOpen(webSocket: WebSocket, response: Response) {}

	override fun onMessage(webSocket: WebSocket, text: String) {
            // TODO: handle these messages

	override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {
            // TODO: handling this would be nice as well
in RxJava, i would extract object to be class, create
inside it, and when
get triggered, push that message to the subject. For client interaction i would be doing
on that subject, obviously.