@@ -356,12 +356,18 @@ obj new_socket(sock: @socket_res) {
356
356
357
357
// Accept connections on a socket.
358
358
fn bind ( endpoint : str ) -> result:: t < ( ) , error > {
359
- _bind ( sock, endpoint)
359
+ // Work around rust bug #1286.
360
+ let sock = sock;
361
+ let rc = str:: as_buf ( endpoint, { |b| libzmq:: zmq_bind ( sock. sock , b) } ) ;
362
+ if rc == -1i32 { err ( errno_to_error ( ) ) } else { ok ( ( ) ) }
360
363
}
361
364
362
365
// Connect a socket.
363
366
fn connect ( endpoint : str ) -> result:: t < ( ) , error > {
364
- _connect ( sock, endpoint)
367
+ // Work around rust bug #1286.
368
+ let sock = sock;
369
+ let rc = str:: as_buf ( endpoint, { |b| libzmq:: zmq_connect ( sock. sock , b) } ) ;
370
+ if rc == -1i32 { err ( errno_to_error ( ) ) } else { ok ( ( ) ) }
365
371
}
366
372
367
373
fn send ( data : [ u8 ] , flags : c_int ) -> result:: t < ( ) , error > {
@@ -407,17 +413,6 @@ obj new_socket(sock: @socket_res) {
407
413
}
408
414
}
409
415
410
- // Work around a bug by moving this out of an object.
411
- fn _bind ( sock : @socket_res , endpoint : str ) -> result:: t < ( ) , error > {
412
- let rc = str:: as_buf ( endpoint, { |b| libzmq:: zmq_bind ( sock. sock , b) } ) ;
413
- if rc == -1i32 { err ( errno_to_error ( ) ) } else { ok ( ( ) ) }
414
- }
415
-
416
- fn _connect ( sock : @socket_res , endpoint : str ) -> result:: t < ( ) , error > {
417
- let rc = str:: as_buf ( endpoint, { |b| libzmq:: zmq_connect ( sock. sock , b) } ) ;
418
- if rc == -1i32 { err ( errno_to_error ( ) ) } else { ok ( ( ) ) }
419
- }
420
-
421
416
// Convert a socket kind into the constant value.
422
417
fn socket_kind_to_i32 ( k : socket_kind ) -> c_int {
423
418
alt k {
0 commit comments