| /external/rust/crates/tokio/src/net/unix/ |
| D | split_owned.rs | 66 pub(crate) fn reunite( in reunite() function
102 pub fn reunite(self, other: OwnedWriteHalf) -> Result<UnixStream, ReuniteError> { in reunite() method
103 reunite(self, other) in reunite()
123 pub fn reunite(self, other: OwnedReadHalf) -> Result<UnixStream, ReuniteError> { in reunite() method
124 reunite(other, self) in reunite()
|
| /external/rust/crates/tokio/src/net/tcp/ |
| D | split_owned.rs | 67 pub(crate) fn reunite( in reunite() function
103 pub fn reunite(self, other: OwnedWriteHalf) -> Result<TcpStream, ReuniteError> { in reunite() method
104 reunite(self, other) in reunite()
210 pub fn reunite(self, other: OwnedReadHalf) -> Result<TcpStream, ReuniteError> { in reunite() method
211 reunite(other, self) in reunite()
|
| /external/rust/crates/futures-util/src/io/ |
| D | split.rs | 41 pub fn reunite(self, other: WriteHalf<T>) -> Result<T, ReuniteError<T>> { in reunite() method
42 self.handle.reunite(other.handle).map_err(|err| { in reunite()
52 pub fn reunite(self, other: ReadHalf<T>) -> Result<T, ReuniteError<T>> { in reunite() method
53 other.reunite(self) in reunite()
|
| /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() method
25 other.reunite(self) in reunite()
60 pub fn reunite(self, other: SplitStream<S>) -> Result<S, ReuniteError<S, Item>> { in reunite() method
61 self.lock.reunite(other.0).map_err(|err| { in reunite()
|
| /external/rust/crates/tokio/tests/ |
| D | tcp_into_split.rs | 57 async fn reunite() -> Result<()> { in reunite() function
72 let read1 = match read1.reunite(write2) { in reunite()
77 read1.reunite(write1).expect("Reunite should succeed"); in reunite()
|
| /external/rust/crates/futures/tests_disabled/ |
| D | bilock.rs | 38 assert_eq!(a.reunite(b).expect("bilock/smoke: reunite error"), 2); in smoke()
78 assert_eq!(a.reunite(b).expect("bilock/concurrent: reunite error"), 2 * N); in concurrent()
|
| /external/rust/crates/futures/tests/ |
| D | split.rs | 69 let join = sink.reunite(stream).expect("test_split: reunite error"); in test_split()
|
| /external/rust/crates/futures-util/src/lock/ |
| D | bilock.rs | 156 pub fn reunite(self, other: Self) -> Result<T, ReuniteError<T>> in reunite() method
|
| /external/libtextclassifier/native/annotator/pod_ner/test_data/ |
| D | vocab.txt | 25373 reunite
|
| /external/jline/src/src/test/resources/jline/example/ |
| D | english.gz | |
| /external/icu/icu4j/main/shared/data/ |
| D | Transliterator_Han_Latin_Definition.txt | 11977 團聚 < to\-reunite;
29624 團聚 > to\-reunite;
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/resources/ |
| D | ospd.txt.gz | |
| /external/cldr/tools/java/org/unicode/cldr/util/data/transforms/ |
| D | en-IPA.txt | 15497 $x{reunite}$x → riunɑɪt ; # runɑɪt
|