Constructors for flat pipes that using serialization-based flattening.
PipeChan
PipePort
ReaderPort
WriterChan
pipe_chan
- Create a FlatChan
from a Chan<~[u8]>
pipe_port
- Create a FlatPort
from a Port<~[u8]>
pipe_stream
- Create a pair of FlatChan
and FlatPort
, backed by pipesreader_port
- Create a FlatPort
from a Reader
writer_chan
- Create a FlatChan
from a Writer
PipeChan
type PipeChan<T> = FlatChan<T, SerializingFlattener<DefaultEncoder, T>, PipeByteChan>
PipePort
type PipePort<T> = FlatPort<T, DeserializingUnflattener<DefaultDecoder, T>, PipeBytePort>
ReaderPort
type ReaderPort<T, R> = FlatPort<T, DeserializingUnflattener<DefaultDecoder, T>, ReaderBytePort<R>>
WriterChan
type WriterChan<T, W> = FlatChan<T, SerializingFlattener<DefaultEncoder, T>, WriterByteChan<W>>
pipe_chan
fn pipe_chan<T: Encodable<DefaultEncoder>>(chan: Chan<~[u8]>) -> PipeChan<T>
Create a FlatChan
from a Chan<~[u8]>
pipe_port
fn pipe_port<T: Decodable<DefaultDecoder>>(port: Port<~[u8]>) -> PipePort<T>
Create a FlatPort
from a Port<~[u8]>
pipe_stream
fn pipe_stream<T: Encodable<DefaultEncoder> Decodable<DefaultDecoder>>() ->
(PipePort<T>, PipeChan<T>)
Create a pair of FlatChan
and FlatPort
, backed by pipes
reader_port
fn reader_port<T: Decodable<DefaultDecoder>, R: Reader>(reader: R) ->
ReaderPort<T, R>
Create a FlatPort
from a Reader
writer_chan
fn writer_chan<T: Encodable<DefaultEncoder>, W: Writer>(writer: W) ->
WriterChan<T, W>
Create a FlatChan
from a Writer