@@ -382,19 +382,19 @@ mod pipesy {
382
382
383
383
#[ allow( non_camel_case_types) ]
384
384
pub mod oneshot {
385
- priv use core :: kinds:: Send ;
385
+ priv use std :: kinds:: Send ;
386
386
use ptr:: to_mut_unsafe_ptr;
387
387
388
388
pub fn init < T : Send > ( ) -> ( server:: Oneshot < T > , client:: Oneshot < T > ) {
389
- pub use core :: pipes:: HasBuffer ;
389
+ pub use std :: pipes:: HasBuffer ;
390
390
391
- let buffer = ~:: core :: pipes:: Buffer {
392
- header : :: core :: pipes:: BufferHeader ( ) ,
391
+ let buffer = ~:: std :: pipes:: Buffer {
392
+ header : :: std :: pipes:: BufferHeader ( ) ,
393
393
data : __Buffer {
394
- Oneshot : :: core :: pipes:: mk_packet :: < Oneshot < T > > ( )
394
+ Oneshot : :: std :: pipes:: mk_packet :: < Oneshot < T > > ( )
395
395
} ,
396
396
} ;
397
- do :: core :: pipes:: entangle_buffer ( buffer) |buffer, data| {
397
+ do :: std :: pipes:: entangle_buffer ( buffer) |buffer, data| {
398
398
data. Oneshot . set_buffer ( buffer) ;
399
399
to_mut_unsafe_ptr ( & mut data. Oneshot )
400
400
}
@@ -403,23 +403,23 @@ mod pipesy {
403
403
pub enum Oneshot < T > { pub send( T ) , }
404
404
#[ allow( non_camel_case_types) ]
405
405
pub struct __Buffer < T > {
406
- Oneshot : :: core :: pipes:: Packet < Oneshot < T > > ,
406
+ Oneshot : :: std :: pipes:: Packet < Oneshot < T > > ,
407
407
}
408
408
409
409
#[ allow( non_camel_case_types) ]
410
410
pub mod client {
411
411
412
- priv use core :: kinds:: Send ;
412
+ priv use std :: kinds:: Send ;
413
413
414
414
#[ allow( non_camel_case_types) ]
415
415
pub fn try_send < T : Send > ( pipe : Oneshot < T > , x_0 : T ) ->
416
- :: core :: option:: Option < ( ) > {
416
+ :: std :: option:: Option < ( ) > {
417
417
{
418
418
use super :: send;
419
419
let message = send ( x_0) ;
420
- if :: core :: pipes:: send ( pipe, message) {
421
- :: core :: pipes:: rt:: make_some ( ( ) )
422
- } else { :: core :: pipes:: rt:: make_none ( ) }
420
+ if :: std :: pipes:: send ( pipe, message) {
421
+ :: std :: pipes:: rt:: make_some ( ( ) )
422
+ } else { :: std :: pipes:: rt:: make_none ( ) }
423
423
}
424
424
}
425
425
@@ -428,21 +428,21 @@ mod pipesy {
428
428
{
429
429
use super :: send;
430
430
let message = send ( x_0) ;
431
- :: core :: pipes:: send ( pipe, message) ;
431
+ :: std :: pipes:: send ( pipe, message) ;
432
432
}
433
433
}
434
434
435
435
#[ allow( non_camel_case_types) ]
436
436
pub type Oneshot < T > =
437
- :: core :: pipes:: SendPacketBuffered < super :: Oneshot < T > ,
437
+ :: std :: pipes:: SendPacketBuffered < super :: Oneshot < T > ,
438
438
super :: __Buffer < T > > ;
439
439
}
440
440
441
441
#[ allow( non_camel_case_types) ]
442
442
pub mod server {
443
443
#[ allow( non_camel_case_types) ]
444
444
pub type Oneshot < T > =
445
- :: core :: pipes:: RecvPacketBuffered < super :: Oneshot < T > ,
445
+ :: std :: pipes:: RecvPacketBuffered < super :: Oneshot < T > ,
446
446
super :: __Buffer < T > > ;
447
447
}
448
448
}
@@ -557,52 +557,52 @@ mod pipesy {
557
557
558
558
#[ allow( non_camel_case_types) ]
559
559
pub mod streamp {
560
- priv use core :: kinds:: Send ;
560
+ priv use std :: kinds:: Send ;
561
561
562
562
pub fn init < T : Send > ( ) -> ( server:: Open < T > , client:: Open < T > ) {
563
- pub use core :: pipes:: HasBuffer ;
564
- :: core :: pipes:: entangle ( )
563
+ pub use std :: pipes:: HasBuffer ;
564
+ :: std :: pipes:: entangle ( )
565
565
}
566
566
567
567
#[ allow( non_camel_case_types) ]
568
568
pub enum Open < T > { pub data( T , server:: Open < T > ) , }
569
569
570
570
#[ allow( non_camel_case_types) ]
571
571
pub mod client {
572
- priv use core :: kinds:: Send ;
572
+ priv use std :: kinds:: Send ;
573
573
574
574
#[ allow( non_camel_case_types) ]
575
575
pub fn try_data < T : Send > ( pipe : Open < T > , x_0 : T ) ->
576
- :: core :: option:: Option < Open < T > > {
576
+ :: std :: option:: Option < Open < T > > {
577
577
{
578
578
use super :: data;
579
- let ( s, c) = :: core :: pipes:: entangle ( ) ;
579
+ let ( s, c) = :: std :: pipes:: entangle ( ) ;
580
580
let message = data ( x_0, s) ;
581
- if :: core :: pipes:: send ( pipe, message) {
582
- :: core :: pipes:: rt:: make_some ( c)
583
- } else { :: core :: pipes:: rt:: make_none ( ) }
581
+ if :: std :: pipes:: send ( pipe, message) {
582
+ :: std :: pipes:: rt:: make_some ( c)
583
+ } else { :: std :: pipes:: rt:: make_none ( ) }
584
584
}
585
585
}
586
586
587
587
#[ allow( non_camel_case_types) ]
588
588
pub fn data < T : Send > ( pipe : Open < T > , x_0 : T ) -> Open < T > {
589
589
{
590
590
use super :: data;
591
- let ( s, c) = :: core :: pipes:: entangle ( ) ;
591
+ let ( s, c) = :: std :: pipes:: entangle ( ) ;
592
592
let message = data ( x_0, s) ;
593
- :: core :: pipes:: send ( pipe, message) ;
593
+ :: std :: pipes:: send ( pipe, message) ;
594
594
c
595
595
}
596
596
}
597
597
598
598
#[ allow( non_camel_case_types) ]
599
- pub type Open < T > = :: core :: pipes:: SendPacket < super :: Open < T > > ;
599
+ pub type Open < T > = :: std :: pipes:: SendPacket < super :: Open < T > > ;
600
600
}
601
601
602
602
#[ allow( non_camel_case_types) ]
603
603
pub mod server {
604
604
#[ allow( non_camel_case_types) ]
605
- pub type Open < T > = :: core :: pipes:: RecvPacket < super :: Open < T > > ;
605
+ pub type Open < T > = :: std :: pipes:: RecvPacket < super :: Open < T > > ;
606
606
}
607
607
}
608
608
0 commit comments