Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Event ¶
type Event interface { Subscription Data() interface{} // contains filtered or unexported methods }
type EventListener ¶
type EventListener func(Event)
type FilterFunc ¶
type FilterFunc func(data interface{}) bool
type FilterMiddleware ¶
type FilterMiddleware struct {
FilterFunc FilterFunc
}
func (*FilterMiddleware) Pipe ¶
func (f *FilterMiddleware) Pipe(evt Event) MiddlewareResult
type FirstMiddleware ¶
type FirstMiddleware struct { }
func (*FirstMiddleware) Pipe ¶
func (f *FirstMiddleware) Pipe(evt Event) MiddlewareResult
type MapMiddleware ¶
type MapMiddleware struct {
// contains filtered or unexported fields
}
func (*MapMiddleware) Pipe ¶
func (f *MapMiddleware) Pipe(evt Event) MiddlewareResult
type Middleware ¶
type Middleware interface {
Pipe(evt Event) MiddlewareResult
}
func Filter ¶
func Filter(fn FilterFunc) Middleware
func First ¶
func First() Middleware
func Map ¶
func Map(fn MapFunc) Middleware
func TakeUntil ¶ added in v0.6.0
func TakeUntil(trigger *Observable) Middleware
type MiddlewareResult ¶
type Observable ¶
type Observable struct {
// contains filtered or unexported fields
}
func (*Observable) Complete ¶
func (o *Observable) Complete()
func (*Observable) Next ¶
func (o *Observable) Next(evt interface{})
func (*Observable) Pipe ¶
func (o *Observable) Pipe(middlewares ...Middleware) *Observable
func (*Observable) Subscribe ¶
func (o *Observable) Subscribe(l Listener) Subscription
func (*Observable) SubscribeEvent ¶
func (o *Observable) SubscribeEvent(l EventListener) Subscription
type Subscription ¶
type Subscription interface { Unsubscribe() // contains filtered or unexported methods }
type TakeUntilFunc ¶ added in v0.6.0
type TakeUntilFunc func(data interface{}) bool
type TakeUntilMiddleware ¶ added in v0.6.0
type TakeUntilMiddleware struct {
// contains filtered or unexported fields
}
func (*TakeUntilMiddleware) Pipe ¶ added in v0.6.0
func (m *TakeUntilMiddleware) Pipe(evt Event) MiddlewareResult
Click to show internal directories.
Click to hide internal directories.