title: 管道流

管道流

管道流允许同步化的形式在两个不同线程的传递数据。

var pipestream = new PipelineStream()

PipelineStream(int capacity = 4096, int sleep = 1);

参数	描述
`capacity`	管道流的容量
`sleep`	等待数据时线程`sleep`的时间

当读取时触发的事件,传入参数为管道流实例。

pipestream.OnRead += (stream)=>{ }

event Action<Stream> OnRead;

判断管道流是否可以被读取。

var readable = pipestream.CanRead;

bool CanRead { get; }

判断管道流是否可以被写入。

var writeable = pipestream.CanWrite;

bool CanWrite { get; }

获取管道流实际传输的位置(流量)（已被读取）。

var position = pipestream.Position;

long Position { get; }

获取管道流需要传输的总长度。如果为0则表示没有限制。

var length = pipestream.Length;

long Length { get; }

是否能够设定Position的位置，在管道流中这个值始终返回false。

pipestream.CanSeek; // false

bool CanSeek { get; }

判断管道流是否已经被关闭。

var closed = pipestream.Closed;

bool Closed { get; }

设定管道流期望传输的总长度（预期长度）。

pipestream.SetLength(100);

void SetLength(long value);

参数	描述
`value`	预期需要传输的长度

读取管道流中的数据,返回值为实际读取的长度。

var read = pipestream.Read(buffer, 0, buffer.Length);

int Read(byte[] buffer, int offset, int count)

向管道流中写入数据,如果写入的数据不能完成写入，那么会挂起等待写入完成。

pipestream.Write(buffer, 0, buffer.Length);

void Write(byte[] buffer, int offset, int count);

关闭管道流,关闭管道流后不能够再写入数据，但是依旧可以读取完全部数据。

pipestream.Close();

void Close();

释放管道流，释放后将不能够读取和写入。

pipestream.Dispose();

void Dispose();