oplog

Documentation

Index

• type Broadcaster
  • func NewBroadcaster() Broadcaster
  • func (b Broadcaster) Listen() Receiver
  • func (b Broadcaster) Write(v interface{})
• type Receiver
  • func (r *Receiver) Read() interface{}

Types

type Broadcaster

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

Broadcaster - defines a pubsub mechanism for distributing events to listeners

func NewBroadcaster

func NewBroadcaster() Broadcaster

NewBroadcaster - create a new broadcaster object.

func (Broadcaster) Listen

func (b Broadcaster) Listen() Receiver

Listen - start listening to the broadcasts.

func (Broadcaster) Write

func (b Broadcaster) Write(v interface{})

Write - broadcast a value to all listeners.

type Receiver

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

Receiver - a listener for events

func (*Receiver) Read

func (r *Receiver) Read() interface{}

Read - read a value that has been broadcast, waiting until one is available if necessary.