Searched refs:futures (Results 1 – 19 of 19) sorted by relevance
18 import concurrent.futures61 self.executor = concurrent.futures.ThreadPoolExecutor(max_workers=1)72 except concurrent.futures.TimeoutError:
18 from concurrent.futures import ThreadPoolExecutor
11 use futures::channel::mpsc;12 use futures::executor::block_on;13 use futures::stream::StreamExt;
9 use futures::executor::block_on;
9 use futures::stream::{self, StreamExt};97 std::boxed::Box<dyn futures::Stream<Item = bt_packets::hci::AclPacket> + std::marker::Send>, in fragmenting_stream()
10 use futures::stream::{SelectAll, StreamExt};
3 use futures::channel::oneshot;
16 futures = "0.3.13" qkey
24 futures = "*" qkey
29 futures = "*" qkey
5 use futures::sink::SinkExt;
32 futures = "*" qkey
33 futures = "*" qkey
35 futures = "0.3" qkey
13 use futures::future;
1619 std::vector<std::future<std::vector<Result<void>>>> futures; in ActivateApexPackages() local1620 futures.reserve(worker_num); in ActivateApexPackages()1622 futures.push_back(std::async(std::launch::async, ActivateApexWorker, in ActivateApexPackages()1630 for (size_t i = 0; i < futures.size(); i++) { in ActivateApexPackages()1631 for (const auto& res : futures[i].get()) { in ActivateApexPackages()
21 from concurrent.futures import ThreadPoolExecutor