We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3cd4cbb commit 5b4f6fcCopy full SHA for 5b4f6fc
juniper_subscriptions/src/lib.rs
@@ -187,8 +187,8 @@ where
187
ready_vec.push(None);
188
}
189
190
- let stream = futures::stream::poll_fn(
191
- move |mut ctx| -> Poll<Option<GraphQLResponse<'a, S>>> {
+ let stream =
+ futures::stream::poll_fn(move |mut ctx| -> Poll<Option<GraphQLResponse<'a, S>>> {
192
let mut obj_iterator = object.iter_mut();
193
194
// Due to having to modify `ready_vec` contents (by-move pattern)
@@ -246,8 +246,7 @@ where
246
} else {
247
Poll::Pending
248
249
- },
250
- );
+ });
251
252
Box::pin(stream)
253
0 commit comments