Documentation
¶
Index ¶
- Constants
- func CreateBidirectionalBuffer(receiveStreamID, sendStreamID int, ch *channel.Channel, ...) *bufio.ReadWriter
- func CreateReader(streamID int, ch *channel.Channel, readyCallback func(int)) *bufio.Reader
- func CreateWriter(streamID int, ch *channel.Channel) *bufio.Writer
- type Buffer
- type RawChannelReader
- type RawChannelWriter
- type StreamDataMessage
Constants ¶
View Source
const ( StreamIDMax = 0x3fff // 16383 MaxChunkLen = 16 * 1024 MaxDataLen = 457 // MDU - 2 - 6 (2 for stream header, 6 for channel envelope) CompressTries = 4 )
Variables ¶
This section is empty.
Functions ¶
func CreateReader ¶
Types ¶
type Buffer ¶
type Buffer struct {
ReadWriter *bufio.ReadWriter
}
type RawChannelReader ¶
type RawChannelReader struct {
// contains filtered or unexported fields
}
func NewRawChannelReader ¶
func NewRawChannelReader(streamID int, ch *channel.Channel) *RawChannelReader
func (*RawChannelReader) AddReadyCallback ¶
func (r *RawChannelReader) AddReadyCallback(cb func(int))
func (*RawChannelReader) HandleMessage ¶
func (r *RawChannelReader) HandleMessage(msg channel.MessageBase) bool
func (*RawChannelReader) RemoveReadyCallback ¶
func (r *RawChannelReader) RemoveReadyCallback(cb func(int))
type RawChannelWriter ¶
type RawChannelWriter struct {
// contains filtered or unexported fields
}
func NewRawChannelWriter ¶
func NewRawChannelWriter(streamID int, ch *channel.Channel) *RawChannelWriter
func (*RawChannelWriter) Close ¶
func (w *RawChannelWriter) Close() error
type StreamDataMessage ¶
func (*StreamDataMessage) GetType ¶
func (m *StreamDataMessage) GetType() uint16
func (*StreamDataMessage) Pack ¶
func (m *StreamDataMessage) Pack() ([]byte, error)
func (*StreamDataMessage) Unpack ¶
func (m *StreamDataMessage) Unpack(data []byte) error
Click to show internal directories.
Click to hide internal directories.