chore(socket): add rep socket poll_next_unpin utility

merklefruit · merklefruit · commit c54318f12aab · 2025-03-04T13:51:30.000+01:00
diff --git a/msg-socket/src/rep/socket.rs b/msg-socket/src/rep/socket.rs
@@ -151,6 +151,11 @@ where
     pub fn local_addr(&self) -> Option<&A> {
         self.local_addr.as_ref()
     }
+
+    /// Returns the next request from the socket using an unpinned interface.
+    pub fn poll_next_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Option<Request<A>>> {
+        Pin::new(self).poll_next(cx)
+    }
 }
 
 impl<T: Transport<A> + Unpin, A: Address> Stream for RepSocket<T, A> {

Original file line number	Diff line number	Diff line change
`@@ -151,6 +151,11 @@ where`
`151`	`151`	`pub fn local_addr(&self) -> Option<&A> {`
`152`	`152`	`self.local_addr.as_ref()`
`153`	`153`	`}`
	`154`	`+`
	`155`	`+ /// Returns the next request from the socket using an unpinned interface.`
	`156`	`+ pub fn poll_next_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Option<Request<A>>> {`
	`157`	`+ Pin::new(self).poll_next(cx)`
	`158`	`+ }`
`154`	`159`	`}`
`155`	`160`
`156`	`161`	`impl<T: Transport<A> + Unpin, A: Address> Stream for RepSocket<T, A> {`