direct

Documentation

Overview

package direct implements a synchronous event dispatcher

Index

• type Dispatcher
  • func New() *Dispatcher
  • func (r *Dispatcher) Chan() <-chan *installpb.ProgressResponse
  • func (r *Dispatcher) Close()
  • func (r *Dispatcher) Send(event dispatcher.Event)

Types

type Dispatcher

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

Dispatcher implements event dispatcher that dispatches events without intermediate buffering. It requires that the receiving side is servicing the notification channel otherwise it will block

func New

func New() *Dispatcher

New creates a new event dispatcher

func (*Dispatcher) Chan

func (r *Dispatcher) Chan() <-chan *installpb.ProgressResponse

Chan returns the channel that receives progress updates

func (*Dispatcher) Close

func (r *Dispatcher) Close()

Close stops the dispatcher internal processes Implements EventDispatcher

func (*Dispatcher) Send

func (r *Dispatcher) Send(event dispatcher.Event)

Send publishes the specified event. Implements EventDispatcher