Skip to content

Commit 8513765

Browse files
committed
RSCBC-140: Update wait_until_ready to use BoxedFuture
1 parent 7732386 commit 8513765

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

sdk/couchbase-core/src/diagnosticscomponent.rs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,8 @@ use crate::service_type::ServiceType;
2121
use chrono::Utc;
2222
use futures::future::join_all;
2323
use futures::stream::FuturesUnordered;
24-
use futures::StreamExt;
24+
use futures::{FutureExt, StreamExt};
25+
use futures_core::future::BoxFuture;
2526
use log::debug;
2627
use serde::ser::SerializeStruct;
2728
use std::collections::HashMap;
@@ -266,11 +267,11 @@ impl<C: Client + 'static, M: KvClientManager> DiagnosticsComponent<C, M> {
266267
let on_behalf_of = opts.on_behalf_of.as_ref();
267268

268269
loop {
269-
let mut handles = FuturesUnordered::<Pin<Box<dyn Future<Output = bool>>>>::new();
270+
let mut handles = FuturesUnordered::<BoxFuture<bool>>::new();
270271
if service_types.contains(&ServiceType::QUERY) {
271272
handles.push(Box::pin(
272273
self.is_query_ready(opts.on_behalf_of.as_ref(), desired_state),
273-
));
274+
))
274275
}
275276

276277
if service_types.contains(&ServiceType::SEARCH) {

0 commit comments

Comments
 (0)