Unable to send message after open the socket ?

[kalanidhidev]

I try to send a message after open the socket but nothing happened?

Could anyone help on this ?

Open the socket : ``` RetrofitHub.chatServices?.observeWebSocketEvent() ?.observeOn(AndroidSchedulers.mainThread()) ?.subscribeOn(Schedulers.io()) ?.subscribe({ Log.d("BKS-1", it.toString())

                    }, {
                     Log.d("BKS-2", it.toString())
                         })

Send the message : 
       
                RetrofitHub.chatServices?.sendChatMessage(
                    SendMessageRequest(
                        SystemClock.currentThreadTimeMillis().toInt(),
                        "Kalanidhi M")
                )l̥

interface ChatServices { @Receive fun observeWebSocketEvent(): Flowable<WebSocket.Event>

@Send
fun sendChatMessage(sendMessageRequest: SendMessageRequest)

@Receive
fun observeSendMessage(): Flowable<SendMessageResponse>

}

val chatServices by lazy { scarletInstance?.create<ChatServices>() }

    val b = OkHttpClient().newBuilder()
        .addInterceptor(getLoggingInterceptor())
    val c = b.build()



    scarletInstance =
        Scarlet.Builder()
            .webSocketFactory(c.newWebSocketFactory(WebConstants.CHAT_URL))
            .addMessageAdapterFactory(MoshiMessageAdapter.Factory())
            .addStreamAdapterFactory(RxJava2StreamAdapterFactory())
            .build()

[joelromanpr]

Try having a look at the presenter from the demo, https://github.com/Tinder/Scarlet/blob/master/demo/src/main/java/com/tinder/app/echo/presenter/EchoBotPresenter.kt .

and the echo bot fragment .

https://github.com/Tinder/Scarlet/blob/3ddd11441e4fc0eeb7b4c8dc38b1ac8c4f6ba5c3/demo/src/main/java/com/tinder/app/echo/view/EchoBotFragment.kt .

One is setting up the stream and the other is just calling it.