diff --git a/tentacle/src/protocol_handle_stream.rs b/tentacle/src/protocol_handle_stream.rs index 1d6706af..77b4db41 100644 --- a/tentacle/src/protocol_handle_stream.rs +++ b/tentacle/src/protocol_handle_stream.rs @@ -249,7 +249,7 @@ where Some(token) = self.notify_receiver.next() => { self.handle_event(ServiceProtocolEvent::Notify { token }).await; }, - res = &mut self.handle.poll(&mut self.handle_context), if self.need_poll => { + res = self.handle.poll(&mut self.handle_context), if self.need_poll => { self.need_poll = res.is_some(); }, _ = &mut recv => break,