receiver

Documentation

Index

• type Receiver
  • func New(src io.Reader) *Receiver
  • func (r *Receiver) Output() <-chan packet.Packet
  • func (r *Receiver) Run(ctx context.Context)

Types

type Receiver

type Receiver struct {
	sync.Mutex
	*common.BaseSubProc
	// contains filtered or unexported fields
}

Receiver reads data from network stream and parses it into Packets, which is comprehensible to Terminal

func New

func New(src io.Reader) *Receiver

New telnet data receiver

func (*Receiver) Output

func (r *Receiver) Output() <-chan packet.Packet

Output packet processed by received

func (*Receiver) Run

func (r *Receiver) Run(ctx context.Context)

Run the receiver loop to read and process data from incoming stream. Any processed packets are input into Receiver.ChPacket, and errors into Receiver.ChErr