| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/pariter/ |
| D | sum.rs | 23 P::Item: Add<Output = P::Item> + Sum + Send, in sum()
36 type Output = P::Item; typedef
37 fn consume(&self, par_iter: P) -> Self::Output { in consume()
40 fn combine(a: Self::Output, b: Self::Output) -> Self::Output { in combine()
|
| 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; typedef
128 fn consume(&self, par_iter: P) -> Self::Output; in consume()
131 fn combine(a: Self::Output, b: Self::Output) -> Self::Output; in combine()
|
| D | for_each.rs | 41 type Output = (); typedef
42 fn consume(&self, par_iter: P) -> Self::Output { in consume()
46 fn combine(_a: Self::Output, _b: Self::Output) -> Self::Output {} in combine()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| D | write_task.rs | 56 type Output = io::Result<usize>; typedef
58 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
96 type Output = io::Result<usize>; typedef
98 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
138 type Output = io::Result<()>; typedef
140 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
175 type Output = io::Result<()>; typedef
177 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
200 type Output = io::Result<()>; typedef
202 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| D | read_task.rs | 59 type Output = io::Result<usize>; typedef
61 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
137 type Output = io::Result<usize>; typedef
139 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
209 type Output = io::Result<usize>; typedef
211 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
244 type Output = io::Result<()>; typedef
246 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
328 type Output = io::Result<usize>; typedef
330 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
[all …]
|
| D | seek_task.rs | 42 type Output = io::Result<u64>; typedef
44 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| D | try_join3.rs | 34 F1: Future<Output = Result<R1, E>>, in try_join3()
35 F2: Future<Output = Result<R2, E>>, in try_join3()
36 F3: Future<Output = Result<R3, E>>, in try_join3()
81 pub(crate) fn take_output(self: Pin<&mut Self>) -> F::Output { in take_output()
94 type Output = Result<(), E>; typedef
96 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | yield_now.rs | 42 type Output = (); typedef
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()
|
| D | join_handle.rs | 100 type Output = Result<R, ScheduleError>; typedef
102 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| D | raw.rs | 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> { in turning_to_get_data()
247 pub(crate) fn poll(&self, context: &mut Context) -> Poll<T::Output> { in poll()
264 pub(crate) fn send_result(&self, output: Result<T::Output, ScheduleError>) { in send_result()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/ |
| D | core.rs | 30 pub(crate) async fn core<P, C>(par_iter: P, consumer: C) -> Result<C::Output, ScheduleError> in core()
79 ) -> Result<C::Output, ScheduleError> in recur()
131 ) -> JoinHandle<Result<C::Output, ScheduleError>> in spawn_task()
156 ) -> Result<C::Output, ScheduleError> in recur_ffrt()
193 ) -> JoinHandle<Result<C::Output, ScheduleError>> in spawn_task_ffrt()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| D | futures.rs | 32 type Output = T; typedef
34 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| D | spawn.rs | 73 pub(crate) fn spawn_async<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_async()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | mod.rs | 191 pub fn spawn<T, R>(&self, task: T) -> JoinHandle<R> in spawn()
200 pub(crate) fn spawn_with_attr<T, R>(&self, task: T, builder: &TaskBuilder) -> JoinHandle<R> in spawn_with_attr()
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/tests/ |
| D | task_cancel.rs | 72 type Output = u8; typedef
74 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| D | timer_test.rs | 99 type Output = u32; typedef
101 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| D | join_set.rs | 50 type Output = u8; typedef
52 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| D | mod.rs | 371 type Output = Result<Option<Headers>, T::Error>; typedef
372 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
396 type Output = Result<usize, T::Error>; typedef
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_http/ylong_http_client/src/async_impl/downloader/ |
| D | operator.rs | 107 type Output = Result<usize, HttpClientError>; typedef
109 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
125 type Output = Result<(), HttpClientError>; typedef
127 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | timeout.rs | 47 type Output = Result<Response, HttpClientError>; typedef
49 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| D | ready.rs | 125 type Output = Ready; typedef
128 fn bitor(self, other: Ready) -> Self::Output { in bitor()
141 type Output = Ready; typedef
144 fn bitand(self, other: Ready) -> Self::Output { in bitand()
150 type Output = Ready; typedef
153 fn sub(self, other: Ready) -> Self::Output { in sub()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | timeout.rs | 70 type Output = Result<T::Output, TimerError>; typedef
72 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| D | operator.rs | 100 type Output = Result<(), HttpClientError>; typedef
102 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | input.rs | 70 type Output = Result<(), DispatchErrorKind>; typedef
72 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| D | io_manager.rs | 170 type Output = Result<(), DispatchErrorKind>; typedef
172 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|