Lines Matching refs:Box

15     fn p2_stream(&self) -> Box<dyn InputStream> {  in p2_stream()
16 Box::new(p2::pipe::ClosedInputStream) in p2_stream()
18 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
19 Box::new(tokio::io::empty()) in async_stream()
23 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream()
24 Box::new(p2::pipe::SinkOutputStream) in p2_stream()
26 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
27 Box::new(tokio::io::empty()) in async_stream()
38 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream()
39 Box::new(p2::pipe::ClosedInputStream) in p2_stream()
41 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
42 Box::new(tokio::io::empty()) in async_stream()
46 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream()
47 Box::new(p2::pipe::SinkOutputStream) in p2_stream()
49 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
50 Box::new(tokio::io::empty()) in async_stream()
61 fn p2_stream(&self) -> Box<dyn InputStream> { in p2_stream()
62 Box::new(p2::pipe::ClosedInputStream) in p2_stream()
64 fn async_stream(&self) -> Box<dyn AsyncRead + Send + Sync> { in async_stream()
65 Box::new(tokio::io::empty()) in async_stream()
76 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream()
77 Box::new(p2::pipe::SinkOutputStream) in p2_stream()
79 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
80 Box::new(tokio::io::empty()) in async_stream()
91 fn p2_stream(&self) -> Box<dyn OutputStream> { in p2_stream()
92 Box::new(p2::pipe::ClosedOutputStream) in p2_stream()
94 fn async_stream(&self) -> Box<dyn AsyncWrite + Send + Sync> { in async_stream()
113 Box::new(AlwaysClosed) in async_stream()