@@ -76,7 +76,7 @@ pub trait Sink01CompatExt: Sink01 {
76
76
/// [`Sink<SinkItem = T, SinkError = E>`](futures::sink::Sink)
77
77
/// into a futures 0.3
78
78
/// [`Sink<SinkItem = T, SinkError = E>`](futures_sink::sink::Sink).
79
- fn compat ( self ) -> Compat01As03Sink < Self , Self :: SinkItem >
79
+ fn compat_sink ( self ) -> Compat01As03Sink < Self , Self :: SinkItem >
80
80
where
81
81
Self : Sized ,
82
82
{
@@ -85,24 +85,6 @@ pub trait Sink01CompatExt: Sink01 {
85
85
}
86
86
impl < Si : Sink01 > Sink01CompatExt for Si { }
87
87
88
- /// Extension trait for futures 0.1 [`Stream`](futures::stream::Stream) and
89
- /// [`Sink`](futures::sink::Sink) combos
90
- pub trait StreamSink01CompatExt : Stream01 + Sink01 {
91
- /// Converts a futures 0.1
92
- /// [`Stream<Item = T, Error = E`](futures::stream::Stream) +
93
- /// [`Sink<SinkItem = T, SinkError = E>`](futures::sink::Sink)
94
- /// into a futures 0.3
95
- /// [`Stream<Item = T, Error = E>`](futures_core::stream::Stream) +
96
- /// [`Sink<SinkItem = T, SinkError = E>`](futures_sink::sink::Sink).
97
- fn compat ( self ) -> Compat01As03Sink < Self , <Self as Sink01 >:: SinkItem >
98
- where
99
- Self : Sized ,
100
- {
101
- Compat01As03Sink :: new ( self )
102
- }
103
- }
104
- impl < S : Stream01 + Sink01 > StreamSink01CompatExt for S { }
105
-
106
88
fn poll_01_to_03 < T , E > ( x : Result < Async01 < T > , E > ) -> task03:: Poll < Result < T , E > > {
107
89
match x {
108
90
Ok ( Async01 :: Ready ( t) ) => task03:: Poll :: Ready ( Ok ( t) ) ,
0 commit comments