@@ -101,7 +101,7 @@ mod test {
101
101
102
102
#[ test]
103
103
pub fn DuplexStream1 ( ) {
104
- let ( mut left, mut right) = DuplexStream :: new ( ) ;
104
+ let ( left, right) = DuplexStream :: new ( ) ;
105
105
106
106
left. send ( ~"abc") ;
107
107
right. send ( 123 ) ;
@@ -112,10 +112,9 @@ mod test {
112
112
113
113
#[test]
114
114
pub fn basic_rendezvous_test() {
115
- let (mut port, chan) = rendezvous();
115
+ let (port, chan) = rendezvous();
116
116
117
117
do spawn {
118
- let mut chan = chan;
119
118
chan.send(" abc");
120
119
}
121
120
@@ -126,9 +125,8 @@ mod test {
126
125
fn recv_a_lot ( ) {
127
126
// Rendezvous streams should be able to handle any number of messages being sent
128
127
do run_in_uv_task {
129
- let ( mut port, chan) = rendezvous ( ) ;
128
+ let ( port, chan) = rendezvous ( ) ;
130
129
do spawn {
131
- let mut chan = chan;
132
130
1000000 . times ( || { chan. send ( ( ) ) } )
133
131
}
134
132
1000000 . times ( || { port. recv ( ) } )
@@ -137,9 +135,8 @@ mod test {
137
135
138
136
#[ test]
139
137
fn send_and_fail_and_try_recv ( ) {
140
- let ( mut port, chan) = rendezvous ( ) ;
138
+ let ( port, chan) = rendezvous ( ) ;
141
139
do spawn {
142
- let mut chan = chan;
143
140
chan. duplex_stream . send ( ( ) ) ; // Can't access this field outside this module
144
141
fail ! ( )
145
142
}
@@ -148,9 +145,8 @@ mod test {
148
145
149
146
#[ test]
150
147
fn try_send_and_recv_then_fail_before_ack ( ) {
151
- let ( port, mut chan) = rendezvous ( ) ;
148
+ let ( port, chan) = rendezvous ( ) ;
152
149
do spawn {
153
- let mut port = port;
154
150
port. duplex_stream . recv ( ) ;
155
151
fail ! ( )
156
152
}
@@ -160,9 +156,8 @@ mod test {
160
156
#[ test]
161
157
#[ should_fail]
162
158
fn send_and_recv_then_fail_before_ack ( ) {
163
- let ( port, mut chan) = rendezvous ( ) ;
159
+ let ( port, chan) = rendezvous ( ) ;
164
160
do spawn {
165
- let mut port = port;
166
161
port. duplex_stream . recv ( ) ;
167
162
fail ! ( )
168
163
}
0 commit comments