diff --git a/src/proto/streams/streams.rs b/src/proto/streams/streams.rs index 7b5c7669..875b6103 100644 --- a/src/proto/streams/streams.rs +++ b/src/proto/streams/streams.rs @@ -1265,10 +1265,7 @@ impl StreamRef { let mut stream = me.store.resolve(self.opaque.key); - me.actions - .send - .poll_reset(cx, &mut stream, mode) - .map_err(From::from) + me.actions.send.poll_reset(cx, &mut stream, mode) } pub fn clone_to_opaque(&self) -> OpaqueStreamRef {