Estoy usando Apollo GraphQL en Android. Estoy usando Apollo ver 3. Tengo una suscripción y puedo suscribirme correctamente y obtener las actualizaciones. El problema es que si enciendo el modo de vuelo, la aplicación falla con la excepción:
java.lang.IllegalStateException: WeSocket queue full at com.apollographql.apollo3.network.ws.DefaultWebSocketEngine$open$3.send(OkHttpWebSocketEngine.kt:90) at com.apollographql.apollo3.network.ws.WsProtocol.sendMessageMapBinary(WsProtocol.kt:92) at com.apollographql.apollo3.network.ws.SubscriptionWsProtocol.stopOperation(SubscriptionWsProtocol.kt:69) at com.apollographql.apollo3.network.ws.WebSocketNetworkTransport$3.invokeSuspend(WebSocketNetworkTransport.kt:144) at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33) at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106) 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:920) He intentado usar catch en el flujo devuelto pero no funciona. Esto es lo que hago:
apolloClient.subscribe(ProfileSubscription()).execute().catch { } El archivo .grapql que define la suscripción es:
subscription Profile { syncStatus { offline } }y creo el cliente Apollo llamando:
ApolloClient.Builder() .networkTransport( WebSocketNetworkTransport( serverUrl = baseUrl ) ).build() La url base usa ws como protocolo:
ws://ec2-xx-xxx-xxx-xx.eu-west-2.compute.amazonaws.com:4000/graphql¿Cómo puedo manejar con gracia las excepciones?
Acabo de manejar la excepción donde comienzo el flujo:
viewModelScope.launch(CoroutineExceptionHandler{ _, _ -> }) { profilesUpdatesUseCase.subscribe() } El método profilesUpdatesUseCase.subscribe() es el que llama:
apolloClient.subscribe(ProfileSubscription()).execute()Por supuesto, ViewModel necesita reiniciar eventualmente el flujo cuando sea posible.