observable

type Observable interface {
	// indicates that the observer is ready to receive notifications from the Observable
	Subscribe(observer Observer)
	// indicates that the observer no longer wants to receive notifications from the Observable
	Unsubscribe(observer Observer)
}

type Observer interface {
	// conveys an item that is emitted by the Observable to the observer
	OnNext(interface{})
	// indicates that the Observable has terminated with a specified error condition and that it will be emitting no further items
	OnError(err error)
	// indicates that the Observable has completed successfully and that it will be emitting no further items
	OnComplete()
}