observer

Documentation

Index

• Variables
• type Observer
  • func New(eventHandlers ...rx.EventHandler) Observer
  • func (ob Observer) Handle(item interface{})
  • func (ob Observer) OnDone()
  • func (ob Observer) OnError(err error)
  • func (ob Observer) OnNext(item interface{})
• type ObserverMock
  • func NewObserverMock() *ObserverMock
  • func (m *ObserverMock) Capture() Observer
  • func (m *ObserverMock) OnDone()
  • func (m *ObserverMock) OnError(err error)
  • func (m *ObserverMock) OnNext(item interface{})

Variables

var DefaultObserver = Observer{
	NextHandler: func(interface{}) {},
	ErrHandler:  func(err error) {},
	DoneHandler: func() {},
}

DefaultObserver guarantees any handler won't be nil.

Types

type Observer

type Observer struct {
	NextHandler handlers.NextFunc
	ErrHandler  handlers.ErrFunc
	DoneHandler handlers.DoneFunc
}

Observer represents a group of EventHandlers.

func New

func New(eventHandlers ...rx.EventHandler) Observer

New constructs a new Observer instance with default Observer and accept any number of EventHandler

func (Observer) Handle

func (ob Observer) Handle(item interface{})

Handle registers Observer to EventHandler.

func (Observer) OnDone

func (ob Observer) OnDone()

OnDone terminates the Observer's internal Observable

func (Observer) OnError

func (ob Observer) OnError(err error)

OnError applies Observer's ErrHandler to an error

func (Observer) OnNext

func (ob Observer) OnNext(item interface{})

OnNext applies Observer's NextHandler to an Item

type ObserverMock

type ObserverMock struct {
	mock.Mock
}

func NewObserverMock

func NewObserverMock() *ObserverMock

func (*ObserverMock) Capture

func (m *ObserverMock) Capture() Observer

func (*ObserverMock) OnDone

func (m *ObserverMock) OnDone()

OnDone provides a mock function with given fields:

func (*ObserverMock) OnError

func (m *ObserverMock) OnError(err error)

OnError provides a mock function with given fields: err

func (*ObserverMock) OnNext

func (m *ObserverMock) OnNext(item interface{})

OnNext provides a mock function with given fields: item