observer

Documentation

Index

• func Lift[F rx.AnonymousObserver[T], T any](fn F) rx.Observer[T]
• func Map[T, V any](obs rx.Observer[T], fn func(V) T) rx.Observer[V]
• func Subscribe[F rx.AnonymousObserver[T], T any](observable rx.Observable[T], fn F) rx.Subscription
• type Anonymous
  • func (a Anonymous[T]) OnComplete()
  • func (a Anonymous[T]) OnError(err error)
  • func (a Anonymous[T]) OnNext(x T)

Functions

func Lift

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

func Map

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

func Subscribe

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

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.