a little details here: socket creation: ``` httpC...

# arrow

[kitttn]

a little details here:

socket creation:

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 Subject<String> inside it, and when onMessage get triggered, push that message to the subject. For client interaction i would be doing .subscribe(message) on that subject, obviously.