Searched defs:Future (Results 1 – 7 of 7) sorted by relevance
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| D | mod.rs | 37 type Future: Future<Output = Result<Self::Stream, Self::Error>> + Unpin + Sync + Send + 'static; typedef 40 fn connect(&self, uri: &Uri) -> Self::Future; in connect() 80 type Future = typedef 83 fn connect(&self, uri: &Uri) -> Self::Future { in connect() 115 type Future = typedef 118 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 | 233 unsafe fn run<T, S>(ptr: NonNull<Header>) -> bool in run() 245 T: Future, in schedule() 256 unsafe fn get_result<T, S>(ptr: NonNull<Header>, res: *mut ()) in get_result() 266 unsafe fn drop_ref<T, S>(ptr: NonNull<Header>) in drop_ref() 275 unsafe fn set_waker<T, S>(ptr: NonNull<Header>, cur_state: usize, waker: *const ()) -> bool in set_waker() 285 unsafe fn drop_join_handle<T, S>(ptr: NonNull<Header>) in drop_join_handle() 295 unsafe fn release<T, S>(ptr: NonNull<Header>) in release() 304 unsafe fn cancel<T, S>(ptr: NonNull<Header>) in cancel() 313 fn create_vtable<T, S>() -> &'static TaskVirtualTable in create_vtable()
|
| D | mod.rs | 113 T: Future, in create_raw_task() 159 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 | 263 pub(crate) fn block_on<T>(&self, future: T) -> T::Output in block_on()
|