rx

Documentation

Index

• type AnonymousObserver
• type CompletionObserver
• type ErrorObserver
• type NextObserver
• type Observable
• type Observer
• type Signal
• type Signaler
• type Subject
• type Subscription
  • func (s Subscription) Unsubscribe()

Types

type AnonymousObserver

type AnonymousObserver[T any] interface {
	~func(T) | ~func(error) | ~func()
}

type CompletionObserver

type CompletionObserver interface {
	OnComplete()
}

type ErrorObserver

type ErrorObserver interface {
	OnError(error)
}

type NextObserver

type NextObserver[T any] interface {
	OnNext(T)
}

type Observable

type Observable[T any] interface {
	Subscribe(Observer[T]) Subscription
}

type Observer

type Observer[T any] interface {
	NextObserver[T]
	ErrorObserver
	CompletionObserver
}

type Signal

type Signal[T any] interface {
	Signaler[T]
	Set(T)
	Subscribe(func(T))
}

type Signaler

type Signaler[T any] interface {
	Get() T
}

type Subject

type Subject[T any] interface {
	Observer[T]
	Observable[T]
}

type Subscription

type Subscription func()

func (Subscription) Unsubscribe

func (s Subscription) Unsubscribe()