js

Documentation

Index

• type ChannelReader
  • func NewChannelReader(source <-chan []byte, cancelFn context.CancelFunc) *ChannelReader
  • func (listener *ChannelReader) Close() error
  • func (listener *ChannelReader) Read(b []byte) (n int, err error)

Types

type ChannelReader

type ChannelReader struct {
	// contains filtered or unexported fields
}

ChannelReader is a reader that reads from a channel of bytes.

func NewChannelReader

func NewChannelReader(source <-chan []byte, cancelFn context.CancelFunc) *ChannelReader

NewChannelReader creates a new ChannelReader from a channel.

Second argument is optional function that will be called when `Close` method is called.

func (*ChannelReader) Close

func (listener *ChannelReader) Close() error

func (*ChannelReader) Read

func (listener *ChannelReader) Read(b []byte) (n int, err error)