Require Watcher::Stream to be Send

Signed-off-by: MOZGIII <[email protected]>
vectordotdev · Jun 8, 2020 · 2b600d8 · 2b600d8
1 parent d9061c3
commit 2b600d8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/kubernetes/watcher.rs b/src/kubernetes/watcher.rs
@@ -17,7 +17,7 @@ pub trait Watcher {
     type StreamError: std::error::Error + Send + 'static;
 
     /// The stream type produced by the watch request.
-    type Stream: Stream<Item = Result<WatchResponse<Self::Object>, Self::StreamError>>;
+    type Stream: Stream<Item = Result<WatchResponse<Self::Object>, Self::StreamError>> + Send;
 
     /// Issues a single watch request and returns a stream results.
     fn watch<'a>(