We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see ourdocumentation.
There was an error while loading.Please reload this page.
1 parent5cef6eb commitb7736aeCopy full SHA for b7736ae
tests/test.rs
@@ -3,8 +3,9 @@ extern crate postgres;
3
externcrate r2d2;
4
externcrate r2d2_postgres;
5
6
-use std::sync::{Arc,Future};
+use std::sync::Arc;
7
use std::sync::mpsc;
8
+use std::thread::Thread;
9
10
use postgres::SslMode;
11
use r2d2_postgres::PostgresConnectionManager;
@@ -20,23 +21,23 @@ fn test_basic() {
20
21
let(s2, r2) = mpsc::channel();
22
23
let pool1 = pool.clone();
-letmut fut1 =Future::spawn(move ||{
24
+lett1 =Thread::scoped(move ||{
25
let conn = pool1.get().unwrap();
26
s1.send(()).unwrap();
27
r2.recv().unwrap();
28
drop(conn);
29
});
30
31
let pool2 = pool.clone();
-letmut fut2 =Future::spawn(move ||{
32
+lett2 =Thread::scoped(move ||{
33
let conn = pool2.get().unwrap();
34
s2.send(()).unwrap();
35
r1.recv().unwrap();
36
37
38
-fut1.get();
39
-fut2.get();
+t1.join().ok().unwrap();
40
+t2.join().ok().unwrap();
41
42
pool.get().unwrap();
43
}