Impl futures::stream::Stream for Controller/Listener

stick/Cargo.toml

@@ -36,3 +36,8 @@ default = ["sdb"]
 gcdb = []
 # Include the stick controller database (button/axis remappings).
 sdb = []
+# Include futures::stream::Stream impl.
+stream = ["dep:futures"]
+
+[dependencies]
+futures = { version = "0.3.30", optional = true }

stick/src/ctlr.rs

@@ -580,6 +580,23 @@ impl Future for Controller {
     }
 }
 
+#[cfg(feature = "stream")]
+impl futures::stream::Stream for Controller {
+    type Item = Event;
+    fn poll_next(
+        self: Pin<&mut Self>,
+        cx: &mut Context<'_>,
+    ) -> Poll<Option<Event>> {
+        match self.poll(cx) {
+            Poll::Pending => Poll::Pending,
+            Poll::Ready(e) => match e {
+                Event::Disconnect => Poll::Ready(None),
+                e => Poll::Ready(Some(e)),
+            },
+        }
+    }
+}
+
 pub trait Rumble {
     fn left(&self) -> f32;
     fn right(&self) -> f32;

stick/src/listener.rs

@@ -36,3 +36,16 @@ impl Future for Listener {
         Pin::new(&mut self.get_mut().0).poll(cx)
     }
 }
+#[cfg(feature = "stream")]
+impl futures::stream::Stream for Listener {
+    type Item = crate::Controller;
+    fn poll_next(
+        self: Pin<&mut Self>,
+        cx: &mut Context<'_>,
+    ) -> Poll<Option<Self::Item>> {
+        match self.poll(cx) {
+            Poll::Ready(c) => Poll::Ready(Some(c)),
+            Poll::Pending => Poll::Pending,
+        }
+    }
+}