We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a7f0488 commit 1ba054aCopy full SHA for 1ba054a
1 file changed
postgres-tokio/src/test.rs
@@ -1,4 +1,4 @@
1
-use futures::{Future, IntoFuture};
+use futures::{Future, Stream};
2
use futures_state_stream::StateStream;
3
use std::error::Error as StdError;
4
use std::time::Duration;
@@ -343,9 +343,10 @@ fn cancel() {
343
let c = c.unwrap();
344
let cancel_data = c.cancel_data();
345
let cancel = Interval::new(Duration::from_secs(1), &handle)
346
+ .unwrap()
347
.into_future()
348
.then(move |r| {
- r.unwrap();
349
+ assert!(r.is_ok());
350
cancel_query("postgres://postgres@localhost",
351
TlsMode::None,
352
cancel_data,
0 commit comments