| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/pariter/ |
| H A D | sum.rs | 23 P::Item: Add<Output = P::Item> + Sum + Send,
34 P::Item: Add<Output = P::Item> + Sum + Send,
36 type Output = P::Item; types
37 fn consume(&self, par_iter: P) -> Self::Output { in consume()
40 fn combine(a: Self::Output, b: Self::Output) -> Self::Output { in combine()
|
| H A D | for_each.rs | 41 type Output = (); types
42 fn consume(&self, par_iter: P) -> Self::Output { in consume()
46 fn combine(_a: Self::Output, _b: Self::Output) -> Self::Output {} in combine()
|
| H A D | mod.rs | 87 ) -> Pin<Box<dyn std::future::Future<Output = Result<(), ScheduleError>> + Send + 'a>> in for_each()
99 ) -> Pin<Box<dyn std::future::Future<Output = Result<Self::Item, ScheduleError>> + Send + 'a>> in sum()
102 Self::Item: Add<Output = Self::Item> + Sum + Send, in sum()
112 ) -> Pin<Box<dyn std::future::Future<Output = Result<C::Output, ScheduleError>> + Send + 'a>> in drive()
125 type Output: Send; types
128 fn consume(&self, par_iter: P) -> Self::Output; in consume()
131 fn combine(a: Self::Output, b: Self::Output) -> Self::Output; in combine()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | try_join3.rs | 34 F1: Future<Output = Result<R1, E>>,
35 F2: Future<Output = Result<R2, E>>,
36 F3: Future<Output = Result<R3, E>>,
70 Ready(F::Output),
81 pub(crate) fn take_output(self: Pin<&mut Self>) -> F::Output {
93 impl<E, R, F: Future<Output = Result<R, E>>> Future for FutureDone<F> {
94 type Output = Result<(), E>; types
96 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| H A D | command.rs | 18 use std::process::{Command as StdCommand, CommandArgs, CommandEnvs, ExitStatus, Output, Stdio};
378 pub fn output(&mut self) -> impl Future<Output = io::Result<Output>> { in output()
406 /// This fn can only obtain `ExitStatus`. To obtain the `Output`, please use
408 pub fn status(&mut self) -> impl Future<Output = io::Result<ExitStatus>> { in status()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | write_task.rs | 56 type Output = io::Result<usize>; types
58 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
96 type Output = io::Result<usize>; types
98 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
138 type Output = io::Result<()>; types
140 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
175 type Output = io::Result<()>; types
177 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
200 type Output = io::Result<()>; types
202 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
[all...] |
| H A D | read_task.rs | 59 type Output = io::Result<usize>; types
61 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
137 type Output = io::Result<usize>; types
139 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
209 type Output = io::Result<usize>; types
211 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
244 type Output = io::Result<()>; types
246 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
328 type Output = io::Result<usize>; types
330 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
364 type Output = io::Result<usize>; global() types
[all...] |
| H A D | seek_task.rs | 42 type Output = io::Result<u64>; types
44 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | timeout.rs | 39 T: Future<Output = Result<Response, HttpClientError>> + Unpin,
41 type Output = Result<Response, HttpClientError>; types
43 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | timeout.rs | 70 type Output = Result<T::Output, TimerError>; types
72 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| H A D | mod.rs | 371 type Output = Result<Option<Headers>, T::Error>; types
372 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
396 type Output = Result<usize, T::Error>; types
398 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
409 ) -> Pin<Box<dyn Future<Output = std::io::Result<()>> + Send + Sync + 'a>> in reuse()
417 ) -> Pin<Box<dyn Future<Output = std::io::Result<()>> + Send + Sync + 'a>> in reuse()
430 ) -> Pin<Box<dyn Future<Output = std::io::Result<()>> + Send + Sync + 'a>> in reuse()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | mod.rs | 193 T: Future<Output = R> + Send + 'static, in spawn()
202 T: Future<Output = R> + Send + 'static,
279 T: Future<Output = R>, in block_on()
287 T: Future<Output = R>, in block_on_inner()
327 T: Future<Output = R>, in block_on_inner()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/ |
| H A D | core.rs | 30 pub(crate) async fn core<P, C>(par_iter: P, consumer: C) -> Result<C::Output, ScheduleError>
79 ) -> Result<C::Output, ScheduleError>
131 ) -> JoinHandle<Result<C::Output, ScheduleError>> in spawn_task()
156 ) -> Result<C::Output, ScheduleError>
193 ) -> JoinHandle<Result<C::Output, ScheduleError>> in spawn_task_ffrt()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | mod.rs | 102 ) -> (Task, JoinHandle<T::Output>)
105 T::Output: Send + 'static,
143 T: Future<Output = R>, in spawn()
161 pub fn block_on<T>(task: T) -> T::Output in block_on()
|
| H A D | raw.rs | 176 StoreData(Result<T::Output, ScheduleError>),
231 fn turning_to_store_data(&self, output: std::result::Result<T::Output, ScheduleError>) { in turning_to_store_data()
238 pub(crate) fn turning_to_get_data(&self) -> Result<T::Output, ScheduleError> {
247 pub(crate) fn poll(&self, context: &mut Context) -> Poll<T::Output> {
264 pub(crate) fn send_result(&self, output: Result<T::Output, ScheduleError>) {
294 let out = &mut *(res.cast::<Poll<Result<T::Output, ScheduleError>>>()); in get_result()
|
| H A D | yield_now.rs | 42 type Output = (); types
45 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
67 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | operator.rs | 107 type Output = Result<usize, HttpClientError>; types
109 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
125 type Output = Result<(), HttpClientError>; types
127 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| H A D | spawn.rs | 37 type Output = R; types
39 fn poll(mut self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
75 T: Future<Output = R>,
|
| H A D | futures.rs | 32 type Output = T; types
34 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | ready.rs | 125 type Output = Ready; types
128 fn bitor(self, other: Ready) -> Self::Output { in bitor()
141 type Output = Ready; types
144 fn bitand(self, other: Ready) -> Self::Output { in bitand()
150 type Output = Ready; types
153 fn sub(self, other: Ready) -> Self::Output { in sub()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | output.rs | 31 Pin<Box<dyn Future<Output = Result<(), SendError<OutputMessage>>> + Send + Sync>>;
52 type Output = Result<(), DispatchErrorKind>; types
54 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
174 OutputMessage::Output(frame) in poll_iterator_frames()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
| H A D | resolver.rs | 32 pub type SocketFuture = Pin<Box<dyn Future<Output = Result<Addrs, StdError>> + Sync + Send>>;
79 type Output = Result<Addrs, StdError>; types
81 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | sync.rs | 40 type Output = usize; types
41 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 212 Pin<Box<dyn Future<Output = Result<(), SendError<RespMessage>>> + Send + Sync>>;
215 Output(Frame),
220 Output(Frame),
564 RespMessage::Output(frame) => Ok(frame),
573 RespMessage::Output(frame) => Ok(frame),
597 RespMessage::Output(frame) => Poll::Ready(Ok(frame)),
609 RespMessage::Output(frame) => Poll::Ready(Ok(frame)),
728 Output(Frame),
821 RespMessage::Output(frame) => Ok(frame),
830 RespMessage::Output(fram
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| H A D | operator.rs | 100 type Output = Result<(), HttpClientError>; types
102 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|