diff --git a/links/gql_dio_link/lib/src/dio_link.dart b/links/gql_dio_link/lib/src/dio_link.dart index 0e317ffa..5f2c20b1 100644 --- a/links/gql_dio_link/lib/src/dio_link.dart +++ b/links/gql_dio_link/lib/src/dio_link.dart @@ -67,7 +67,8 @@ class DioLink extends Link { @override Stream request(Request request, [forward]) async* { - final dio.Response> dioResponse = + try { + final dio.Response> dioResponse = await _executeDioRequest( request: request, headers: { @@ -96,6 +97,10 @@ class DioLink extends Link { response: gqlResponse.response, context: _updateResponseContext(gqlResponse, dioResponse), ); + } + catch (e) { + yield* Stream.error(e); + } } dynamic _prepareRequestBody(Request request) {