Current SSE session implementation (e.g. OkHttpSSESession) might not propagate exceptions to the flow collectors. Use "client.prepareGet.execute" chain to properly catch exceptions.

In my case socket timeout was the reason OkHttp: Socket timeouts without timeout configured

Setting socketTimeoutMillis = Long.MAX_VALUE solved the issue for me.