eventloop

Documentation

Index

• type ChanLoop
  • func (el *ChanLoop) Send(ev Event) error
  • func (el *ChanLoop) Start() error
• type Event
• type EventLoop
  • func NewChanLoop(q int) EventLoop

Types

type ChanLoop

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

ChanLoop is implementation of EventLoop based on channels.

func (*ChanLoop) Send

func (el *ChanLoop) Send(ev Event) error

Send sends event to channel. Will block if buffer is full.

func (*ChanLoop) Start

func (el *ChanLoop) Start() error

Start starting to read events from channel in separate goroutines. All calls after first is no-op.

type Event

type Event interface {
	Handle()
}

Event is receiving notification from loop with Handle() call.

type EventLoop

type EventLoop interface {
	Start() error
	Send(Event) error
}

EventLoop is interface for event loops. Start starting events processing Send adding event to loop

func NewChanLoop

func NewChanLoop(q int) EventLoop

NewChanLoop returns ChanLoop with internal channel buffer set to q.