EventSourceListener

MainActivity.kt

val eventSourceListener = object : EventSourceListener() {
    override fun onOpen(eventSource: EventSource, response: Response) {
        super.onOpen(eventSource, response)
        Log.d(MainActivity.TAG, "Connection Opened")
    }

    override fun onClosed(eventSource: EventSource) {
        super.onClosed(eventSource)
        Log.d(MainActivity.TAG, "Connection Closed")
    }

    override fun onEvent(
        eventSource: EventSource,
        id: String?,
        type: String?,
        data: String
    ) {
        super.onEvent(eventSource, id, type, data)
        Log.d(MainActivity.TAG, "On Event Received! Data -: $data")
    }

    override fun onFailure(eventSource: EventSource, t: Throwable?, response: Response?) {
        super.onFailure(eventSource, t, response)
        Log.d(MainActivity.TAG, "On Failure -: ${response?.body}")
    }
}