| /dports/net/oha/oha-0.4.7/cargo-crates/tokio-stream-0.1.7/src/wrappers/ |
| H A D | watch.rs | 55 async fn make_future<T: Clone + Send + Sync>( in make_future() function
79 self.inner.set(make_future(rx)); in poll_next()
83 self.inner.set(make_future(rx)); in poll_next()
|
| H A D | broadcast.rs | 40 async fn make_future<T: Clone>(mut rx: Receiver<T>) -> (Result<T, RecvError>, Receiver<T>) { in make_future() function
49 inner: ReusableBoxFuture::new(make_future(rx)), in new()
58 self.inner.set(make_future(rx)); in poll_next()
|
| /dports/textproc/mdbook/mdBook-0.4.13/cargo-crates/tokio-stream-0.1.7/src/wrappers/ |
| H A D | watch.rs | 55 async fn make_future<T: Clone + Send + Sync>( in make_future() function
79 self.inner.set(make_future(rx)); in poll_next()
83 self.inner.set(make_future(rx)); in poll_next()
|
| H A D | broadcast.rs | 40 async fn make_future<T: Clone>(mut rx: Receiver<T>) -> (Result<T, RecvError>, Receiver<T>) { in make_future() function
49 inner: ReusableBoxFuture::new(make_future(rx)), in new()
58 self.inner.set(make_future(rx)); in poll_next()
|
| /dports/devel/pijul/pijul-1.0.0.a55/cargo-crates/tokio-stream-0.1.7/src/wrappers/ |
| H A D | watch.rs | 55 async fn make_future<T: Clone + Send + Sync>( in make_future() function
79 self.inner.set(make_future(rx)); in poll_next()
83 self.inner.set(make_future(rx)); in poll_next()
|
| H A D | broadcast.rs | 40 async fn make_future<T: Clone>(mut rx: Receiver<T>) -> (Result<T, RecvError>, Receiver<T>) { in make_future() function
49 inner: ReusableBoxFuture::new(make_future(rx)), in new()
58 self.inner.set(make_future(rx)); in poll_next()
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/tokio-stream/src/wrappers/ |
| H A D | watch.rs | 55 async fn make_future<T: Clone + Send + Sync>( in make_future() function
79 self.inner.set(make_future(rx)); in poll_next()
83 self.inner.set(make_future(rx)); in poll_next()
|
| H A D | broadcast.rs | 40 async fn make_future<T: Clone>(mut rx: Receiver<T>) -> (Result<T, RecvError>, Receiver<T>) { in make_future() function
49 inner: ReusableBoxFuture::new(make_future(rx)), in new()
58 self.inner.set(make_future(rx)); in poll_next()
|
| /dports/audio/ncspot/ncspot-0.9.3/cargo-crates/tokio-stream-0.1.8/src/wrappers/ |
| H A D | watch.rs | 55 async fn make_future<T: Clone + Send + Sync>( in make_future() function
79 self.inner.set(make_future(rx)); in poll_next()
83 self.inner.set(make_future(rx)); in poll_next()
|
| H A D | broadcast.rs | 40 async fn make_future<T: Clone>(mut rx: Receiver<T>) -> (Result<T, RecvError>, Receiver<T>) {
49 inner: ReusableBoxFuture::new(make_future(rx)),
58 self.inner.set(make_future(rx));
|
| /dports/net/routinator/routinator-0.10.2/cargo-crates/tokio-stream-0.1.7/src/wrappers/ |
| H A D | broadcast.rs | 40 async fn make_future<T: Clone>(mut rx: Receiver<T>) -> (Result<T, RecvError>, Receiver<T>) { in make_future() function
49 inner: ReusableBoxFuture::new(make_future(rx)), in new()
58 self.inner.set(make_future(rx)); in poll_next()
|
| /dports/editors/helix/helix-0.5.0/cargo-crates/tokio-stream-0.1.7/src/wrappers/ |
| H A D | broadcast.rs | 40 async fn make_future<T: Clone>(mut rx: Receiver<T>) -> (Result<T, RecvError>, Receiver<T>) { in make_future() function
49 inner: ReusableBoxFuture::new(make_future(rx)), in new()
58 self.inner.set(make_future(rx)); in poll_next()
|
| /dports/devel/hpx/hpx-1.2.1/hpx/parallel/segmented_algorithms/ |
| H A D | minmax.hpp | 143 hpx::make_future<SegIter>( in segmented_minormax()
160 hpx::make_future<SegIter>( in segmented_minormax()
178 hpx::make_future<SegIter>( in segmented_minormax()
195 hpx::make_future<SegIter>( in segmented_minormax()
429 hpx::make_future<result_type>( in segmented_minmax()
448 hpx::make_future<result_type>( in segmented_minmax()
468 hpx::make_future<result_type>( in segmented_minmax()
487 hpx::make_future<result_type>( in segmented_minmax()
|
| H A D | find.hpp | 147 hpx::make_future<FwdIter>( in segmented_find()
167 hpx::make_future<FwdIter>( in segmented_find()
188 hpx::make_future<FwdIter>( in segmented_find()
208 hpx::make_future<FwdIter>( in segmented_find()
|
| /dports/devel/hyperscan/boost_1_75_0/boost/compute/algorithm/detail/ |
| H A D | copy_to_device.hpp | 130 return make_future(result + static_cast<difference_type>(count), event_); in copy_to_device_async()
170 return make_future(result + count, event_); in copy_to_device_async()
|
| /dports/devel/boost-python-libs/boost_1_72_0/boost/compute/algorithm/detail/ |
| H A D | copy_to_host.hpp | 131 return make_future(iterator_plus_distance(result, count), event_); in copy_to_host_async()
171 return make_future(iterator_plus_distance(result, count), event_); in copy_to_host_async()
|
| /dports/science/py-scipy/scipy-1.7.1/scipy/_lib/boost/boost/compute/algorithm/detail/ |
| H A D | copy_to_device.hpp | 130 return make_future(result + static_cast<difference_type>(count), event_); in copy_to_device_async()
170 return make_future(result + count, event_); in copy_to_device_async()
|
| H A D | copy_to_host.hpp | 131 return make_future(iterator_plus_distance(result, count), event_); in copy_to_host_async()
171 return make_future(iterator_plus_distance(result, count), event_); in copy_to_host_async()
|
| /dports/devel/R-cran-BH/BH/inst/include/boost/compute/algorithm/detail/ |
| H A D | copy_to_device.hpp | 130 return make_future(result + static_cast<difference_type>(count), event_); in copy_to_device_async()
170 return make_future(result + count, event_); in copy_to_device_async()
|
| H A D | copy_to_host.hpp | 131 return make_future(iterator_plus_distance(result, count), event_); in copy_to_host_async()
171 return make_future(iterator_plus_distance(result, count), event_); in copy_to_host_async()
|
| /dports/math/stanmath/math-4.2.0/lib/boost_1.75.0/boost/compute/algorithm/detail/ |
| H A D | copy_to_device.hpp | 130 return make_future(result + static_cast<difference_type>(count), event_); in copy_to_device_async()
170 return make_future(result + count, event_); in copy_to_device_async()
|
| H A D | copy_to_host.hpp | 131 return make_future(iterator_plus_distance(result, count), event_); in copy_to_host_async()
171 return make_future(iterator_plus_distance(result, count), event_); in copy_to_host_async()
|
| /dports/security/keybase/client-v5.7.1/shared/ios/Pods/boost-for-react-native/boost/compute/algorithm/detail/ |
| H A D | copy_on_device.hpp | 144 return make_future(result + std::distance(first, last), event_); in copy_on_device_async()
182 return make_future(result + count, event_); in copy_on_device_async()
|
| H A D | copy_to_device.hpp | 124 return make_future(result + static_cast<difference_type>(count), event_); in copy_to_device_async()
162 return make_future(result + count, event_); in copy_to_device_async()
|
| H A D | copy_to_host.hpp | 125 return make_future(iterator_plus_distance(result, count), event_); in copy_to_host_async()
163 return make_future(iterator_plus_distance(result, count), event_); in copy_to_host_async()
|