We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 37a5fdd commit 8d9d9faCopy full SHA for 8d9d9fa
1 file changed
src/test/test.rs
@@ -62,20 +62,21 @@ fn test_pool() {
62
let pool = or_fail!(PostgresConnectionPool::new("postgres://postgres@localhost",
63
NoSsl, 2));
64
65
- let (stream1, stream2) = comm::duplex();
+ let (s1, r1) = comm::channel();
66
+ let (s2, r2) = comm::channel();
67
68
let pool1 = pool.clone();
69
let mut fut1 = Future::spawn(proc() {
70
let _conn = pool1.get_connection();
- stream1.send(());
71
- stream1.recv();
+ s1.send(());
72
+ r2.recv();
73
});
74
75
let pool2 = pool.clone();
76
let mut fut2 = Future::spawn(proc() {
77
let _conn = pool2.get_connection();
- stream2.send(());
78
- stream2.recv();
+ s2.send(());
79
+ r1.recv();
80
81
82
fut1.get();
0 commit comments