observer

Documentation

Index

• func Bind[T, V any](obs rx.Observer[T], fn func(rx.Observer[T]) V) rx.Observer[V]
• func Filter[T any](obs rx.Observer[T], predicate func(T) bool) rx.Observer[T]
• func Lift[F rx.AnonymousObserver[T], T any](fn F) rx.Observer[T]
• func Lift2[F rx.AnonymousObserver2[K, V], K, V any](fn F) rx.Observer2[K, V]
• func Subscribe[O rx.AnonymousObserver[T], T any](observable rx.Observable[T], fn O) rx.Subscription
• func WithNext[T any](obs rx.Observer[T], next func(T)) rx.Observer[T]
• type Anonymous
  • func (a Anonymous[T]) OnComplete()
  • func (a Anonymous[T]) OnError(err error)
  • func (a Anonymous[T]) OnNext(x T)
• type Anonymous2
  • func (a Anonymous2[K, V]) OnComplete()
  • func (a Anonymous2[K, V]) OnError(err error)
  • func (a Anonymous2[K, V]) OnNext(k K, v V)

Functions

func Bind

func Bind[T, V any](obs rx.Observer[T], fn func(rx.Observer[T]) V) rx.Observer[V]

func Filter

func Filter[T any](obs rx.Observer[T], predicate func(T) bool) rx.Observer[T]

func Lift

func Lift[F rx.AnonymousObserver[T], T any](fn F) rx.Observer[T]

func Lift2

func Lift2[F rx.AnonymousObserver2[K, V], K, V any](fn F) rx.Observer2[K, V]

func Subscribe

func Subscribe[O rx.AnonymousObserver[T], T any](
	observable rx.Observable[T], fn O,
) rx.Subscription

func WithNext

func WithNext[T any](obs rx.Observer[T], next func(T)) rx.Observer[T]

Types

type Anonymous

type Anonymous[T any] struct {
	Complete func()
	Error    func(error)
	Next     func(T)
}

func (Anonymous[T]) OnComplete

func (a Anonymous[T]) OnComplete()

OnComplete implements rx.Observer.

func (Anonymous[T]) OnError

func (a Anonymous[T]) OnError(err error)

OnError implements rx.Observer.

func (Anonymous[T]) OnNext

func (a Anonymous[T]) OnNext(x T)

OnNext implements rx.Observer.

type Anonymous2

type Anonymous2[K, V any] struct {
	Complete func()
	Error    func(error)
	Next     func(K, V)
}

func (Anonymous2[K, V]) OnComplete

func (a Anonymous2[K, V]) OnComplete()

OnComplete implements rx.Observer.

func (Anonymous2[K, V]) OnError

func (a Anonymous2[K, V]) OnError(err error)

OnError implements rx.Observer.

func (Anonymous2[K, V]) OnNext

func (a Anonymous2[K, V]) OnNext(k K, v V)

OnNext implements rx.Observer.