observable

Documentation

Index

• func Map[T, V any](obs rx.Observable[T], fn func(T) V) rx.Observable[V]
• func New[T any](options ...subject.Option[T]) rx.Observable[T]
• type Anonymous
  • func (a Anonymous[T]) Subscribe(obs rx.Observer[T]) rx.Subscription
• type Subscriber

Functions

func Map

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

func New

func New[T any](options ...subject.Option[T]) rx.Observable[T]

Types

type Anonymous

type Anonymous[T any] func(rx.Observer[T]) rx.Subscription

func (Anonymous[T]) Subscribe

func (a Anonymous[T]) Subscribe(obs rx.Observer[T]) rx.Subscription

Subscribe implements rx.Observable.

type Subscriber

type Subscriber[T any] interface {
	Next(T)
	Error(error)
	Complete()
}