SSERepository.kt

private val sseClient = OkHttpClient.Builder()
        .connectTimeout(6, TimeUnit.SECONDS)
        .readTimeout(10, TimeUnit.MINUTES)
        .writeTimeout(10, TimeUnit.MINUTES)
        .build()

private val sseRequest = Request.Builder()
        .url(EVENTSURL)
        .header("Accept", "application/json")
        .addHeader("Accept", "text/event-stream")
        .build()
        
private val sseEventSourceListener = object : EventSourceListener() {
    override fun onClosed(eventSource: EventSource) {}

    override fun onEvent(eventSource: EventSource, id: String?, type: String?, data: String) { }

    override fun onFailure(eventSource: EventSource, t: Throwable?, response: Response?) {}

    override fun onOpen(eventSource: EventSource, response: Response) {}
}
    
    
private fun initEventSource() {
    EventSources.createFactory(sseClient)
        .newEventSource(request = sseRequest, listener = sseEventSourceListener)
}