File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -155,7 +155,7 @@ public class Server {
155
155
subscribeFuture. whenSuccess { result in
156
156
guard let streamOpt = result. stream else {
157
157
// API issue - subscribe resolver isn't stream
158
- self . error ( . internalAPIStreamIssue ( errors: result . errors ) )
158
+ self . sendError ( result . errors, id : id )
159
159
return
160
160
}
161
161
let stream = streamOpt as! ObservableSubscriptionEventStream
@@ -177,12 +177,11 @@ public class Server {
177
177
onCompleted: { [ weak self] in
178
178
guard let self = self else { return }
179
179
self . sendComplete ( id: id)
180
- self . messenger? . close ( )
181
180
}
182
181
) . disposed ( by: self . disposeBag)
183
182
}
184
183
subscribeFuture. whenFailure { error in
185
- self . error ( . graphQLError ( error) )
184
+ self . sendError ( error, id : id )
186
185
}
187
186
}
188
187
else {
@@ -205,7 +204,6 @@ public class Server {
205
204
self . error ( . notInitialized( ) )
206
205
return
207
206
}
208
- onExit ( )
209
207
}
210
208
211
209
private func onConnectionTerminate( _: ConnectionTerminateRequest , _ messenger: Messenger ) {
You can’t perform that action at this time.
0 commit comments