emitter

Documentation

Index

• Variables
• type Emitter

Variables

var (
	ErrClosed = errors.New("streamwrite is closed")
)

Types

type Emitter

type Emitter interface {
	Work(w io.StreamWriter) error
	Bus(w io.StreamWriter) (io.Bus, bool)
	Stop(w io.StreamWriter)
	StopAll()
}

Emitter receives new messages and emits through outlet.