| /dports/lang/rust/rustc-1.58.1-src/src/test/ui/suggestions/ |
| H A D | expected-boxed-future-isnt-pinned.rs | 6 type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + Send + 'a>>; typedef
9 fn foo<F: Future<Output=i32> + Send + 'static>(x: F) -> BoxFuture<'static, i32> { in foo()
14 fn bar<F: Future<Output=i32> + Send + 'static>(x: F) -> BoxFuture<'static, i32> { in bar()
18 fn baz<F: Future<Output=i32> + Send + 'static>(x: F) -> BoxFuture<'static, i32> { in baz()
23 fn qux<F: Future<Output=i32> + Send + 'static>(x: F) -> BoxFuture<'static, i32> { in qux()
27 fn zap() -> BoxFuture<'static, i32> { in zap()
|
| H A D | box-future-wrong-output.rs | 7 pub type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + Send + 'a>>; typedef
11 fn boxed<'a>(self) -> BoxFuture<'a, Self::Output> in boxed()
20 let _: BoxFuture<'static, bool> = async {}.boxed(); in main()
|
| /dports/editors/helix/helix-0.5.0/cargo-crates/jsonrpc-core-18.0.0/src/ |
| H A D | calls.rs | 2 use crate::BoxFuture;
17 fn into_future(self) -> BoxFuture<Result<T, E>>; in into_future()
21 fn into_future(self) -> BoxFuture<Result<T, E>> { in into_future()
26 impl<T, E> WrapFuture<T, E> for BoxFuture<Result<T, E>> { implementation
27 fn into_future(self) -> BoxFuture<Result<T, E>> { in into_future()
35 fn call(&self, params: Params) -> BoxFuture<crate::Result<Value>>; in call()
49 fn call(&self, params: Params, meta: T) -> BoxFuture<crate::Result<Value>>; in call()
102 fn call(&self, params: Params) -> BoxFuture<crate::Result<Value>> { in call()
122 fn call(&self, params: Params, meta: T) -> BoxFuture<crate::Result<Value>> { in call()
|
| /dports/editors/kak-lsp/kak-lsp-11.1.0/cargo-crates/jsonrpc-core-18.0.0/src/ |
| H A D | calls.rs | 2 use crate::BoxFuture;
17 fn into_future(self) -> BoxFuture<Result<T, E>>; in into_future()
21 fn into_future(self) -> BoxFuture<Result<T, E>> { in into_future()
26 impl<T, E> WrapFuture<T, E> for BoxFuture<Result<T, E>> { implementation
27 fn into_future(self) -> BoxFuture<Result<T, E>> { in into_future()
35 fn call(&self, params: Params) -> BoxFuture<crate::Result<Value>>; in call()
49 fn call(&self, params: Params, meta: T) -> BoxFuture<crate::Result<Value>>; in call()
102 fn call(&self, params: Params) -> BoxFuture<crate::Result<Value>> { in call()
122 fn call(&self, params: Params, meta: T) -> BoxFuture<crate::Result<Value>> { in call()
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/jsonrpc-core/src/ |
| H A D | calls.rs | 2 use crate::BoxFuture;
17 fn into_future(self) -> BoxFuture<Result<T, E>>; in into_future()
21 fn into_future(self) -> BoxFuture<Result<T, E>> { in into_future()
26 impl<T, E> WrapFuture<T, E> for BoxFuture<Result<T, E>> { implementation
27 fn into_future(self) -> BoxFuture<Result<T, E>> { in into_future()
35 fn call(&self, params: Params) -> BoxFuture<crate::Result<Value>>; in call()
49 fn call(&self, params: Params, meta: T) -> BoxFuture<crate::Result<Value>>; in call()
102 fn call(&self, params: Params) -> BoxFuture<crate::Result<Value>> { in call()
122 fn call(&self, params: Params, meta: T) -> BoxFuture<crate::Result<Value>> { in call()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/surf-1.0.3/src/middleware/ |
| H A D | mod.rs | 55 use futures::future::BoxFuture;
66 ) -> BoxFuture<'a, Result<Response, Exception>>; in handle()
75 + for<'a> Fn(Request, C, Next<'a, C>) -> BoxFuture<'a, Result<Response, Exception>>,
82 ) -> BoxFuture<'a, Result<Response, Exception>> { in handle()
91 endpoint: &'a (dyn (Fn(Request, C) -> BoxFuture<'static, Result<Response, Exception>>)
112 endpoint: &'a (dyn (Fn(Request, C) -> BoxFuture<'static, Result<Response, Exception>>) in new()
124 pub fn run(mut self, req: Request, client: C) -> BoxFuture<'a, Result<Response, Exception>> { in run()
|
| /dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/generic/threadshare/src/runtime/ |
| H A D | task.rs | 118 fn prepare(&mut self) -> BoxFuture<'_, Result<(), gst::ErrorMessage>> { in prepare()
122 fn unprepare(&mut self) -> BoxFuture<'_, ()> { in unprepare()
126 fn start(&mut self) -> BoxFuture<'_, Result<(), gst::ErrorMessage>> { in start()
131 fn iterate(&mut self) -> BoxFuture<'_, Result<(), gst::FlowError>>; in iterate()
133 fn pause(&mut self) -> BoxFuture<'_, Result<(), gst::ErrorMessage>> { in pause()
145 fn stop(&mut self) -> BoxFuture<'_, Result<(), gst::ErrorMessage>> { in stop()
205 ) -> BoxFuture<'_, Trigger> { in handle_action_error()
1246 fn unprepare(&mut self) -> BoxFuture<'_, ()> { in iterate()
1499 ) -> BoxFuture<'_, Trigger> { in prepare_error()
1590 ) -> BoxFuture<'_, Trigger> { in prepare_start_ok()
[all …]
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/jsonrpc-derive/examples/ |
| H A D | meta-macros.rs | 4 use jsonrpc_core::{BoxFuture, MetaIoHandler, Metadata, Params, Result, Value};
33 fn call(&self, a: u64) -> BoxFuture<Result<String>>; in call()
37 fn call_meta(&self, a: Self::Metadata, b: BTreeMap<String, Value>) -> BoxFuture<Result<String>>; in call_meta()
64 fn call(&self, x: u64) -> BoxFuture<Result<String>> { in call()
68 …fn call_meta(&self, meta: Self::Metadata, map: BTreeMap<String, Value>) -> BoxFuture<Result<String… in call_meta()
|
| H A D | generic-trait.rs | 3 use jsonrpc_core::{BoxFuture, IoHandler, Result};
18 fn call(&self, a: One) -> BoxFuture<Result<(One, Two)>>; in call()
33 fn call(&self, num: u64) -> BoxFuture<Result<(u64, String)>> { in call()
|
| H A D | generic-trait-bounds.rs | 3 use jsonrpc_core::{futures::future, BoxFuture, IoHandler, IoHandlerExtension, Result};
24 fn call(&self, a: One) -> BoxFuture<Result<(One, u64)>>; in call()
51 fn call(&self, num: InAndOut) -> BoxFuture<Result<(InAndOut, u64)>> { in call()
|
| H A D | std.rs | 4 use jsonrpc_core::{BoxFuture, IoHandler, Result};
21 fn call(&self, a: u64) -> BoxFuture<Result<String>>; in call()
39 fn call(&self, _: u64) -> BoxFuture<Result<String>> { in call()
|
| H A D | client-local.rs | 3 BoxFuture, IoHandler, Result,
21 fn call(&self, a: u64) -> BoxFuture<Result<String>>; in call()
35 fn call(&self, _: u64) -> BoxFuture<Result<String>> { in call()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/actix-service-1.0.6/src/ |
| H A D | boxed.rs | 9 pub type BoxFuture<I, E> = Pin<Box<dyn Future<Output = Result<I, E>>>>; typedef
12 Box<dyn Service<Request = Req, Response = Res, Error = Err, Future = BoxFuture<Res, Err>>>;
52 Future = BoxFuture<BoxService<Req, Res, Err>, InitErr>,
70 type Future = BoxFuture<Self::Service, InitErr>;
105 type Future = BoxFuture<Self::Service, Self::InitError>;
136 type Future = BoxFuture<Res, Err>;
|
| /dports/www/miniserve/miniserve-0.18.0/cargo-crates/actix-service-2.0.0/src/ |
| H A D | boxed.rs | 11 pub type BoxFuture<T> = Pin<Box<dyn Future<Output = T>>>; typedef
18 dyn Service<Req, Response = Res, Error = Err, Future = BoxFuture<Result<Res, Err>>>,
54 type Future = BoxFuture<Result<Res, Err>>;
90 Future = BoxFuture<Result<BoxService<Req, Res, Err>, InitErr>>,
108 type Future = BoxFuture<Result<Self::Service, InitErr>>;
133 type Future = BoxFuture<Result<Self::Service, Self::InitError>>;
|
| /dports/lang/rust/rustc-1.58.1-src/src/test/ui/issues/ |
| H A D | issue-75777.rs | 9 type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + 'a + Send>>; typedef
11 fn inject<'a, Env: 'a, A: 'a + Send>(v: A) -> Box<dyn FnOnce(&'a Env) -> BoxFuture<'a, A>> { in inject()
12 let fut: BoxFuture<'a, A> = Box::pin(future::ready(v)); in inject()
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/tower-util-0.1.0/src/boxed/ |
| H A D | sync.rs | 14 inner: Box<dyn Service<T, Response = U, Error = E, Future = BoxFuture<U, E>> + Send>,
21 type BoxFuture<T, E> = Box<dyn Future<Item = T, Error = E> + Send>; typedef
42 type Future = BoxFuture<U, E>;
48 fn call(&mut self, request: T) -> BoxFuture<U, E> { in call()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/tower-util-0.1.0/src/boxed/ |
| H A D | sync.rs | 14 inner: Box<dyn Service<T, Response = U, Error = E, Future = BoxFuture<U, E>> + Send>,
21 type BoxFuture<T, E> = Box<dyn Future<Item = T, Error = E> + Send>; typedef
42 type Future = BoxFuture<U, E>;
48 fn call(&mut self, request: T) -> BoxFuture<U, E> { in call()
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/jsonrpc-derive/tests/run-pass/ |
| H A D | client_with_generic_trait_bounds.rs | 2 use jsonrpc_core::{IoHandler, Result, BoxFuture};
18 fn call(&self, a: One) -> BoxFuture<Result<(One, Two)>>; in call()
29 fn call(&self, num: u64) -> BoxFuture<Result<(u64, String)>> { in call()
|
| /dports/sysutils/vector/tower-c87fdd9c1e4c0728fdaa87d3fafe3e48da9b498a/tower/src/util/boxed/ |
| H A D | sync.rs | 18 inner: Box<dyn Service<T, Response = U, Error = E, Future = BoxFuture<U, E>> + Send>,
25 type BoxFuture<T, E> = Pin<Box<dyn Future<Output = Result<T, E>> + Send>>; typedef
47 type Future = BoxFuture<U, E>;
53 fn call(&mut self, request: T) -> BoxFuture<U, E> { in call()
|
| /dports/lang/rust/rustc-1.58.1-src/src/test/ui/higher-rank-trait-bounds/normalize-under-binder/ |
| H A D | issue-80706.rs | 4 type BoxFuture<T> = std::pin::Pin<Box<dyn std::future::Future<Output=T>>>; typedef
21 fn execute(&self) -> BoxFuture<Result<(), String>> { in execute()
41 ) -> BoxFuture<Result<<Self as StorageRequestReturnType>::Output, <S as Storage>::Error>>; in execute()
|
| /dports/multimedia/librespot/librespot-0.1.3/cargo-crates/tokio-threadpool-0.1.18/src/task/ |
| H A D | mod.rs | 53 future: UnsafeCell<Option<Spawn<BoxFuture>>>,
63 type BoxFuture = Box<dyn Future<Item = (), Error = ()> + Send + 'static>; typedef
69 pub fn new(future: BoxFuture) -> Task { in new()
86 let future = Box::new(futures::empty()) as BoxFuture; in stub()
131 struct Guard<'a>(&'a mut Option<Spawn<BoxFuture>>, bool); in run()
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/tokio-threadpool-0.1.18/src/task/ |
| H A D | mod.rs | 53 future: UnsafeCell<Option<Spawn<BoxFuture>>>,
63 type BoxFuture = Box<dyn Future<Item = (), Error = ()> + Send + 'static>; typedef
69 pub fn new(future: BoxFuture) -> Task { in new()
86 let future = Box::new(futures::empty()) as BoxFuture; in stub()
131 struct Guard<'a>(&'a mut Option<Spawn<BoxFuture>>, bool); in run()
|
| /dports/net-mgmt/nfs-exporter/freebsd-nfs-exporter-0.3.0/cargo-crates/tokio-threadpool-0.1.18/src/task/ |
| H A D | mod.rs | 53 future: UnsafeCell<Option<Spawn<BoxFuture>>>,
63 type BoxFuture = Box<dyn Future<Item = (), Error = ()> + Send + 'static>; typedef
69 pub fn new(future: BoxFuture) -> Task { in new()
86 let future = Box::new(futures::empty()) as BoxFuture; in stub()
131 struct Guard<'a>(&'a mut Option<Spawn<BoxFuture>>, bool); in run()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/tokio-threadpool-0.1.17/src/task/ |
| H A D | mod.rs | 53 future: UnsafeCell<Option<Spawn<BoxFuture>>>,
63 type BoxFuture = Box<dyn Future<Item = (), Error = ()> + Send + 'static>; typedef
69 pub fn new(future: BoxFuture) -> Task { in new()
86 let future = Box::new(futures::empty()) as BoxFuture; in stub()
131 struct Guard<'a>(&'a mut Option<Spawn<BoxFuture>>, bool); in run()
|
| /dports/www/geckodriver/mozilla-central-e9783a644016aa9b317887076618425586730d73/testing/geckodriver/cargo-crates/tokio-threadpool-0.1.14/src/task/ |
| H A D | mod.rs | 53 future: UnsafeCell<Option<Spawn<BoxFuture>>>,
63 type BoxFuture = Box<Future<Item = (), Error = ()> + Send + 'static>; typedef
69 pub fn new(future: BoxFuture) -> Task { in new()
86 let future = Box::new(futures::empty()) as BoxFuture; in stub()
131 struct Guard<'a>(&'a mut Option<Spawn<BoxFuture>>, bool); in run()
|