How to catch exceptions from ApolloClient watch method?

Question

This code - manual query execution without watch - throws an exception as I expect it (due to an intentionally wrong server url not shown here):

try {
    val response = apolloClient.query(MyQuery()).execute()
} catch (e: Exception) {
    Timber.e("exception from manual execution")
    Timber.e(e)
}

However, if instead I use watch (and intentionally the same wrong server url) like in the following code, I get no exception:

try {
    apolloClient.query(MyQuery())
        .watch() // flow
        .collect { response ->
            Timber.i("apollo watch collect called")
        }
} catch (e: Exception) {
    Timber.e("exception from watch execution")
    Timber.e(e)
}

Where is my error? Why don't I get an exception in the second case? How to catch errors when using watch?

By default watch method will not throw an exception will return an error object as part of the query result — Sagar Sainkar, Apr 05 '23 at 10:22

score 1 · Accepted Answer · edited Apr 05 '23 at 11:02

1

apolloClient.query(MyQuery())
        .watch( fetchThrows = true, refetchThrows = true) // need this
        .catch{t->}//catch here
        .collect { response ->
            Timber.i("apollo watch collect called")
        }

edited Apr 05 '23 at 11:02

stefan.at.kotlin

15,347
38
147
270

answered Mar 31 '23 at 22:33

Shift Delete

1,015
6
13

1

thank you, that worked fine and looks the most intuitive to me :-) it needs to be combined with `.watch( fetchThrows = true, refetchThrows = true)` though. – stefan.at.kotlin Apr 05 '23 at 10:59

score 0 · Answer 2 · answered Mar 30 '23 at 02:38

0

use a callback on the ApolloQueryWatcher instance. Here is an example from GitHub

Also use .responseFetcher(ApolloResponseFetchers.CACHE_ONLY) with any enqueueAndWatch calls to make sure that watchers won't perform any network requests when the cache is updated and prevent Infinite loops

answered Mar 30 '23 at 02:38

RAI

584
9

You Github example seems to be for an older version of Apollo Kotlin – stefan.at.kotlin Mar 30 '23 at 21:08

score 0 · Answer 3 · answered Apr 01 '23 at 16:39

The collect function starts the flow and consumes the emitted values, but it does not throw any exceptions.

Use the onCompletion operator to handle any errors that occur during the execution of the flow.

apolloClient.query(MyQuery())
    .watch()
    .onCompletion { throwable ->
        if (throwable != null) {
            Timber.e("error from watch execution")
            Timber.e(throwable)
        }
    }
    .collect { response ->
        Timber.i("apollo watch collect called")
    }

A slight improvement: if the emitted values are being ignored it is possible to just use
.launchIn(scope) instead of .collect { response -> ...

thank you for your reply. I went with the `catch` way though as it seems more intuitive to me. — stefan.at.kotlin, Apr 05 '23 at 10:59

How to catch exceptions from ApolloClient watch method?

3 Answers3