demultiplexer

Documentation

Index

• type Demultiplexer
  • func NewDemultiplexer(ctx context.Context, in <-chan model.TransferRequest, bufferSize int) (*Demultiplexer, error)
  • func (dm *Demultiplexer) Run(ctx context.Context) error
  • func (dm *Demultiplexer) Stream(chName string) <-chan model.TransferRequest

Types

type Demultiplexer

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

func NewDemultiplexer

func NewDemultiplexer(ctx context.Context, in <-chan model.TransferRequest, bufferSize int) (*Demultiplexer, error)

func (*Demultiplexer) Run

func (dm *Demultiplexer) Run(ctx context.Context) error

func (*Demultiplexer) Stream

func (dm *Demultiplexer) Stream(chName string) <-chan model.TransferRequest