| /external/rust/crates/tokio/src/net/unix/ |
| D | split_owned.rs | 69 ) -> Result<UnixStream, ReuniteError> { in reunite() argument
76 Err(ReuniteError(read, write)) in reunite()
83 pub struct ReuniteError(pub OwnedReadHalf, pub OwnedWriteHalf); struct
85 impl fmt::Display for ReuniteError { implementation
94 impl Error for ReuniteError {} implementation
102 pub fn reunite(self, other: OwnedWriteHalf) -> Result<UnixStream, ReuniteError> { in reunite() argument
123 pub fn reunite(self, other: OwnedReadHalf) -> Result<UnixStream, ReuniteError> { in reunite() argument
|
| D | mod.rs | 11 pub use split_owned::{OwnedReadHalf, OwnedWriteHalf, ReuniteError};
|
| /external/rust/crates/tokio/src/net/tcp/ |
| D | split_owned.rs | 70 ) -> Result<TcpStream, ReuniteError> { in reunite() argument
77 Err(ReuniteError(read, write)) in reunite()
84 pub struct ReuniteError(pub OwnedReadHalf, pub OwnedWriteHalf); struct
86 impl fmt::Display for ReuniteError { implementation
95 impl Error for ReuniteError {} implementation
103 pub fn reunite(self, other: OwnedWriteHalf) -> Result<TcpStream, ReuniteError> { in reunite() argument
210 pub fn reunite(self, other: OwnedReadHalf) -> Result<TcpStream, ReuniteError> { in reunite() argument
|
| D | mod.rs | 11 pub use split_owned::{OwnedReadHalf, OwnedWriteHalf, ReuniteError};
|
| /external/rust/crates/futures-util/src/io/ |
| D | split.rs | 41 pub fn reunite(self, other: WriteHalf<T>) -> Result<T, ReuniteError<T>> { in reunite()
43 ReuniteError(ReadHalf { handle: err.0 }, WriteHalf { handle: err.1 }) in reunite()
52 pub fn reunite(self, other: ReadHalf<T>) -> Result<T, ReuniteError<T>> { in reunite()
95 pub struct ReuniteError<T>(pub ReadHalf<T>, pub WriteHalf<T>); struct
97 impl<T> fmt::Debug for ReuniteError<T> { implementation
105 impl<T> fmt::Display for ReuniteError<T> { implementation
112 impl<T: core::any::Any> std::error::Error for ReuniteError<T> {} implementation
|
| D | mod.rs | 129 pub use self::split::{ReadHalf, WriteHalf, ReuniteError};
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | split.rs | 22 pub fn reunite<Item>(self, other: SplitSink<S, Item>) -> Result<S, ReuniteError<S, Item>> in reunite()
60 pub fn reunite(self, other: SplitStream<S>) -> Result<S, ReuniteError<S, Item>> { in reunite()
62 ReuniteError(SplitSink(err.0), SplitStream(err.1)) in reunite()
126 pub struct ReuniteError<T, Item>(pub SplitSink<T, Item>, pub SplitStream<T>); struct
128 impl<T, Item> fmt::Debug for ReuniteError<T, Item> { implementation
136 impl<T, Item> fmt::Display for ReuniteError<T, Item> { implementation
143 impl<T: core::any::Any, Item> std::error::Error for ReuniteError<T, Item> {} implementation
|
| D | mod.rs | 199 pub use self::split::{SplitStream, SplitSink, ReuniteError};
|
| /external/rust/crates/futures-util/src/lock/ |
| D | bilock.rs | 156 pub fn reunite(self, other: Self) -> Result<T, ReuniteError<T>> in reunite()
167 Err(ReuniteError(self, other)) in reunite()
204 pub struct ReuniteError<T>(pub BiLock<T>, pub BiLock<T>); struct
206 impl<T> fmt::Debug for ReuniteError<T> { implementation
214 impl<T> fmt::Display for ReuniteError<T> { implementation
221 impl<T: core::any::Any> std::error::Error for ReuniteError<T> {} implementation
|
| D | mod.rs | 18 pub use self::bilock::{BiLock, BiLockAcquire, BiLockGuard, ReuniteError};
|
| /external/rust/crates/futures/tests/ |
| D | auto_traits.rs | 800 assert_impl!(ReuniteError<()>: Send);
801 assert_not_impl!(ReuniteError<*const ()>: Send);
802 assert_impl!(ReuniteError<()>: Sync);
803 assert_not_impl!(ReuniteError<*const ()>: Sync);
804 assert_impl!(ReuniteError<PhantomPinned>: Unpin);
938 assert_impl!(ReuniteError<()>: Send);
940 assert_not_impl!(ReuniteError<*const ()>: Send);
942 assert_impl!(ReuniteError<()>: Sync);
944 assert_not_impl!(ReuniteError<*const ()>: Sync);
946 assert_impl!(ReuniteError<PhantomPinned>: Unpin);
[all …]
|
| /external/rust/crates/futures-util/src/stream/ |
| D | mod.rs | 47 pub use self::stream::{ReuniteError, SplitSink, SplitStream};
|