Searched defs:Future (Results 1 – 7 of 7) sorted by relevance
| /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()
75 pub(crate) fn new<T>(header: &Header) -> WakerRefHeader<'_> in new()
|
| D | raw.rs | 289 unsafe fn get_result<T, S>(ptr: NonNull<Header>, res: *mut ()) in get_result()
299 unsafe fn drop_ref<T, S>(ptr: NonNull<Header>) in drop_ref()
308 unsafe fn set_waker<T, S>(ptr: NonNull<Header>, cur_state: usize, waker: *const ()) -> bool in set_waker()
318 unsafe fn drop_join_handle<T, S>(ptr: NonNull<Header>) in drop_join_handle()
|
| D | mod.rs | 121 T: Future, in create_raw_task()
161 pub fn block_on<T>(task: T) -> T::Output in block_on()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| D | mod.rs | 42 type Future: Future<Output = Result<Self::Stream, HttpClientError>> typedef
49 fn connect(&self, uri: &Uri, http_version: HttpVersion) -> Self::Future; in connect()
171 type Future = typedef
174 fn connect(&self, uri: &Uri, _http_version: HttpVersion) -> Self::Future { in connect()
245 type Future = typedef
248 fn connect(&self, uri: &Uri, _http_version: HttpVersion) -> Self::Future { in connect()
|
| /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 | 270 pub(crate) fn block_on<T>(&self, future: T) -> T::Output in block_on()
|