Documentation
¶
Index ¶
- func Bind[T, V any](src rx.Observable[T], fn func(T) rx.Observable[V]) rx.Observable[V]
- func Filter[T any](src rx.Observable[T], predicate func(T) bool) rx.Observable[T]
- func Lift[O rx.AnonymousObservable[T], T any](obs O) rx.Observable[T]
- func Lift2[O rx.AnonymousObservable2[K, V], K, V any](obs O) rx.Observable2[K, V]
- func Map[T, V any](src rx.Observable[T], project func(T) V) rx.Observable[V]
- func New[T any](options ...subject.Option[T]) rx.Observable[T]
- type Anonymous
- type Anonymous2
- type Subscriber
- type Writer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Bind ¶ added in v0.0.24
func Bind[T, V any](src rx.Observable[T], fn func(T) rx.Observable[V]) rx.Observable[V]
Bind is still TODO
func Filter ¶ added in v0.0.24
func Filter[T any](src rx.Observable[T], predicate func(T) bool) rx.Observable[T]
func Lift ¶ added in v0.0.24
func Lift[O rx.AnonymousObservable[T], T any](obs O) rx.Observable[T]
func Lift2 ¶ added in v0.0.24
func Lift2[O rx.AnonymousObservable2[K, V], K, V any](obs O) rx.Observable2[K, V]
func Map ¶
func Map[T, V any](src rx.Observable[T], project func(T) V) rx.Observable[V]
Types ¶
type Anonymous2 ¶ added in v0.0.24
type Anonymous2[K, V any] func(rx.Observer2[K, V]) rx.Subscription
func (Anonymous2[K, V]) Subscribe ¶ added in v0.0.24
func (a Anonymous2[K, V]) Subscribe(obs rx.Observer2[K, V]) rx.Subscription
Subscribe implements rx.Observable2.
type Subscriber ¶ added in v0.0.10
type Writer ¶ added in v0.0.24
type Writer interface {
io.WriteCloser
rx.Observable[[]byte]
}
Source Files
Click to show internal directories.
Click to hide internal directories.