| /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()
207 type Output = io::Result<usize>; typedef
209 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
242 type Output = io::Result<()>; typedef
244 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
326 type Output = io::Result<usize>; typedef
328 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/task/ |
| D | yield_now.rs | 43 type Output = (); typedef
46 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
68 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| D | join_handle.rs | 93 type Output = Result<R, ScheduleError>; typedef
95 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| D | task_handle.rs | 70 fn finish(self, state: usize, output: Result<T::Output, ScheduleError>) { in finish()
138 pub(crate) fn get_result(self, out: &mut Poll<std::result::Result<T::Output, ScheduleError>>) { in get_result()
270 fn ffrt_finish(self, state: usize, output: Result<T::Output, ScheduleError>) { in ffrt_finish()
|
| D | raw.rs | 183 fn turning_to_store_data(&self, output: std::result::Result<T::Output, ScheduleError>) { in turning_to_store_data()
190 pub(crate) fn turning_to_get_data(&self) -> Result<T::Output, ScheduleError> { in turning_to_get_data()
199 pub(crate) fn poll(&self, context: &mut Context) -> Poll<T::Output> { in poll()
216 pub(crate) fn send_result(&self, output: Result<T::Output, ScheduleError>) { in send_result()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | timeout.rs | 32 type Output = Result<Response<HttpBody>, HttpClientError>; typedef
34 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /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 | 33 pub(crate) fn spawn_async<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_async()
|
| D | lib.rs | 73 pub fn spawn<T, R>(task: T) -> JoinHandle<R> in spawn()
|
| /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/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 | join_set.rs | 50 type Output = u8; typedef
52 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| D | block_on.rs | 301 type Output = usize; typedef
302 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|
| /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_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()
|
| D | sleep.rs | 137 type Output = (); typedef
139 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/executor/ |
| D | mod.rs | 190 pub fn spawn<T, R>(&self, task: T) -> JoinHandle<R> in spawn()
199 pub(crate) fn spawn_with_attr<T, R>(&self, task: T, builder: &TaskBuilder) -> JoinHandle<R> in spawn_with_attr()
275 T: Future<Output = R>, in block_on()
|
| /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_runtime/ylong_runtime/src/sync/ |
| D | oneshot.rs | 390 type Output = Result<T, RecvError>; typedef
392 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
|