obs

Documentation

Index

• func FromAnonymous[T any](observable func(rx.Subscriber[T])) rx.Observable[T]
• func New[T any](options ...subject.Option[T]) rx.Observable[T]
• type Anonymous
  • func (a Anonymous[T]) Subscribe(observer rx.Observer[T]) rx.Subscription

Functions

func FromAnonymous

func FromAnonymous[T any](observable func(rx.Subscriber[T])) rx.Observable[T]

func New

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

Types

type Anonymous

type Anonymous[T any] func(rx.Subscriber[T])

func (Anonymous[T]) Subscribe

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

Subscribe implements rx.Observable.