process

Documentation

Index

• type Processor
  • func NewProcessor(messageChan <-chan network.Message, respChan chan<- network.Message, ...) *Processor
  • func (processor *Processor) RunAsync(ctx context.Context)

Types

type Processor

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

func NewProcessor

func NewProcessor(messageChan <-chan network.Message, respChan chan<- network.Message, actionPicker *setup.ActionPicker) *Processor

func (*Processor) RunAsync

func (processor *Processor) RunAsync(ctx context.Context)