Versions in this module Expand all Collapse all v1 v1.24.4 Aug 19, 2016 Changes in this version + var ErrIOTimeout = errors.New("IO Timeout") + type InboundRay interface + InboundInput func() OutputStream + InboundOutput func() InputStream + type InputStream interface + Close func() + type OutboundRay interface + OutboundInput func() InputStream + OutboundOutput func() OutputStream + type OutputStream interface + Close func() + type Ray interface + func NewRay() Ray + type Stream struct + func NewStream() *Stream + func (this *Stream) Close() + func (this *Stream) Read() (*alloc.Buffer, error) + func (this *Stream) Release() + func (this *Stream) TryWriteOnce(data *alloc.Buffer) error + func (this *Stream) Write(data *alloc.Buffer) error