Searched defs:Future (Results 1 – 8 of 8) sorted by relevance
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | connector.rs | 33 type Future: Future<Output = Result<Self::Stream, Self::Error>> + Unpin + Sync + Send + 'static; typedef
36 fn connect(&self, uri: &Uri) -> Self::Future; in connect()
85 type Future = typedef
88 fn connect(&self, uri: &Uri) -> Self::Future { in connect()
116 type Future = typedef
119 fn connect(&self, uri: &Uri) -> Self::Future { in connect()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | waker.rs | 33 unsafe fn clone<T>(ptr: *const ()) -> RawWaker in clone()
60 fn raw_waker<T>(header: *const Header) -> RawWaker in raw_waker()
77 pub(crate) fn new<T>(header: &Header) -> WakerRefHeader<'_> in new()
|
| D | raw.rs | 241 unsafe fn run<T, S>(ptr: NonNull<Header>) -> bool in run()
253 T: Future, in schedule()
264 unsafe fn get_result<T, S>(ptr: NonNull<Header>, res: *mut ()) in get_result()
274 unsafe fn drop_ref<T, S>(ptr: NonNull<Header>) in drop_ref()
283 unsafe fn set_waker<T, S>(ptr: NonNull<Header>, cur_state: usize, waker: *const ()) -> bool in set_waker()
293 unsafe fn drop_join_handle<T, S>(ptr: NonNull<Header>) in drop_join_handle()
303 unsafe fn release<T, S>(ptr: NonNull<Header>) in release()
312 unsafe fn cancel<T, S>(ptr: NonNull<Header>) in cancel()
321 fn create_vtable<T, S>() -> &'static TaskVirtualTable in create_vtable()
|
| D | mod.rs | 113 T: Future, in create_raw_task()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| D | lib.rs | 93 pub fn block_on<T>(task: T) -> T::Output in block_on()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | timeout.rs | 44 pub fn timeout<F>(duration: Duration, future: F) -> Timeout<F> in timeout()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | block_on.rs | 94 pub(crate) fn block_on<T>(mut task: T) -> T::Output in block_on()
|
| D | current_thread.rs | 146 pub(crate) fn block_on<T>(&self, future: T) -> T::Output in block_on()
|