receiver

Documentation

Index

• type Receiver
  • func NewReceiver(source chan *message.Message) *Receiver
  • func (r *Receiver) Receive() *message.Message

Types

type Receiver

type Receiver struct {
	Source chan *message.Message
}

Receiver represents a receiver that can receive messages

func NewReceiver

func NewReceiver(source chan *message.Message) *Receiver

NewReceiver creates a new receiver

func (*Receiver) Receive

func (r *Receiver) Receive() *message.Message

Receive receives a message from the source