rx

package

v0.2.2 Latest Latest Go to latest Published: Jan 5, 2025 License: MIT Imports: 0 Imported by: 3

Details

This section is empty.

This section is empty.

This section is empty.

type AnonymousObservable[T any] interface {
	~func(Observer[T]) Subscription
}

type AnonymousObservable2[K, V any] interface {
	~func(Observer2[K, V]) Subscription
}

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

type AnonymousObserver2[K, V any] interface {
	~func(K, V) | ~func(error) | ~func()
}

type CompletionObserver interface {
	OnComplete()
}

type ErrorObserver interface {
	OnError(error)
}

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

type NextObserver2[K, V any] interface {
	OnNext(K, V)
}

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

type Observable2[K, V any] interface {
	Subscribe(Observer2[K, V]) Subscription
}

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

type Observer2[K, V any] interface {
	NextObserver2[K, V]
	ErrorObserver
	CompletionObserver
}

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

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

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

type Subject2[K, V any] interface {
	Observer2[K, V]
	Observable2[K, V]
}

type Subscription func()

func (s Subscription) Unsubscribe()