I start a subscription as seen in the code snippet My unders

Question

I start a subscription as seen in the code snippet My understanding is that it will catch any exceptions and restart the flow but in reality my app is crashing with the exception below ```subscription someSubscription toFlow retryWhen t attempt gt delay attempt attempt 10000 true ``` ```java io EOFException null at okio RealBufferedSource require RealBufferedSource kt 199 at okio RealBufferedSource readByte RealBufferedSource kt 209 at okhttp3 internal ws WebSocketReader readHeader WebSocketReader kt 119 at okhttp3 internal ws WebSocketReader processNextFrame WebSocketReader kt 102 at okhttp3 internal ws RealWebSocket loopReader RealWebSocket kt 293 at okhttp3 internal ws RealWebSocket$connect$1 onResponse RealWebSocket kt 195 at okhttp3 internal connection RealCall$AsyncCall run RealCall kt 519 at java util concurrent ThreadPoolExecutor runWorker ThreadPoolExecutor java 1167 at java util concurrent ThreadPoolExecutor$Worker run ThreadPoolExecutor java 641 at java lang Thread run Thread java 764 com apollographql apollo3 exception ApolloNetworkException Network error while executing onDisplayTimeUpdated at com apollographql apollo3 network ws WebSocketNetworkTransport$execute$$inlined$map$1$2 emit Emitters kt 246 at kotlinx coroutines flow internal SafeCollectorKt$emitFun$1 invoke SafeCollector kt 15 at kotlinx coroutines flow internal SafeCollectorKt$emitFun$1 invoke SafeCollector kt 15 at kotlinx coroutines flow internal SafeCollector emit SafeCollector kt 87 at kotlinx coroutines flow internal SafeCollector emit SafeCollector kt 66 at com apollographql apollo3 network ws WebSocketNetworkTransport$execute$3 invokeSuspend WebSocketNetworkTransport kt 271 at com apollographql apollo3 network ws WebSocketNetworkTransport$execute$3 invoke at com apollographql apollo3 network ws WebSocketNetworkTransport$execute$3 invoke at com apollographql apollo3 internal FlowsKt$transformWhile$1$invokeSuspend$$inlined$collectWhile$1 emit flows kt 53 at com apollographql apollo3 internal FlowsKt$transformWhile$1$invokeSuspend$$inlined$collectWhile$2 emit flows kt 38 at com apollographql apollo3 network ws WebSocketNetworkTransport$execute$$inlined$filter$1$2 emit Emitters kt 223 at kotlinx coroutines flow SubscribedFlowCollector emit at kotlinx coroutines flow SharedFlowImpl collect$suspendImpl SharedFlow kt 383 at kotlinx coroutines flow SharedFlowImpl$collect$1 invokeSuspend at kotlin coroutines jvm internal BaseContinuationImpl resumeWith ContinuationImpl kt 33 at kotlinx coroutines DispatchedTask run DispatchedTask kt 106 at kotlinx coroutines internal LimitedDispatcher run LimitedDispatcher kt 42 at kotlinx coroutines scheduling TaskImpl run Tasks kt 95 at kotlinx coroutines scheduling CoroutineScheduler runSafely CoroutineScheduler kt 570 at kotlinx coroutines scheduling CoroutineScheduler$Worker executeTask CoroutineScheduler kt 750 at kotlinx coroutines scheduling CoroutineScheduler$Worker runWorker CoroutineScheduler kt 677 at kotlinx coroutines scheduling CoroutineScheduler$Worker run CoroutineScheduler kt 664 ```

mbonnin · Answer

Mmm that s unexpected let me check if I can reproduce What version are you on

Parijat Shah · Answer

3 7 4

mbonnin · Answer

Can t reproduce using the integration <https github com apollographql apollo kotlin blob 17dcc07370ad7d87a3dfe3286c08ba3d2fb24032 tests websockets src jvmTest kotlin SampleServerTest kt L53|tests> disappointed

mbonnin · Answer

I m doing this ``` fun simple val apolloClient = ApolloClient Builder serverUrl <http localhost 61504 subscriptions> build runBlocking val list = apolloClient subscription CountSubscription 5 10000 toFlow retryWhen cause attempt gt println retrying because cause printStackTrace delay attempt attempt 10000 true map it data count toList assertEquals 0 until 5 toList list ```

mbonnin · Answer

And killing the server to simulate a network error

mbonnin · Answer

What scope context are you running your Flow in I know error handling in Flows can be quite complicated maybe it s related to that

Parijat Shah · Answer

Sorry about the late response was in a meeting I am using custom scope with Main Dispatcher ```coroutineScope = CoroutineScope Dispatchers Main + SupervisorJob ```

Parijat Shah · Answer

My unit test works as well

mbonnin · Answer

by works you mean it doesn t throw right

mbonnin · Answer

Does it say anything else in the stack trace It s weird that there are 2 stacktraces but no caused by

mbonnin · Answer

Have to call it a day for tonight but if you can setup a reproducer I ll look into it on Monday

Parijat Shah · Answer

gt by works you mean it doesn t throw right In my unit test I am throwing exception and the behavior is as expected retry block starts the flow again ```retryWhen t attempt gt delay attempt attempt 10000 true ```

Parijat Shah · Answer

Just the update I released a patch with enabling option `webSocketReopenWhen` and don t see the exception anymore

Parijat Shah · Answer

``` ApolloClient Builder webSocketReopenWhen attempt gt some delay true ```

mbonnin · Answer

Nice thanks for the update