We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2f811c9 commit 4387ddeCopy full SHA for 4387dde
src/join_stream.rs
@@ -1,4 +1,3 @@
1
-use std::marker::PhantomData;
2
use std::pin::Pin;
3
use std::task::{Context, Poll};
4
@@ -8,26 +7,21 @@ use futures_core::Stream;
8
7
///
9
/// This stream is returned by `join!`.
10
#[derive(Debug)]
11
-pub struct JoinStream<L, R, T> {
+pub struct JoinStream<L, R> {
12
left: L,
13
right: R,
14
- _marker: PhantomData<T>,
15
}
16
17
-impl<L, R, T> Unpin for JoinStream<L, R, T> {}
+impl<L, R> Unpin for JoinStream<L, R> {}
18
19
-impl<L, R, T> JoinStream<L, R, T> {
+impl<L, R> JoinStream<L, R> {
20
#[doc(hidden)]
21
pub fn new(left: L, right: R) -> Self {
22
- Self {
23
- left,
24
- right,
25
- _marker: PhantomData,
26
- }
+ Self { left, right }
27
28
29
30
-impl<L, R, T> Stream for JoinStream<L, R, T>
+impl<L, R, T> Stream for JoinStream<L, R>
31
where
32
L: Stream<Item = T> + Unpin,
33
R: Stream<Item = T> + Unpin,
0 commit comments