Class Observable<A>`Internal`

A computation which may asynchronously publish 0-or-more values to a subscribing Observer.

An Observable<A> for some type A defines a double negation of values of type A.

See

Wire a sub-class for event broadcasting.
Behavior for a dynamic store (as seen in Svelte).

Type Parameters

A
the value type published by this Observable.

Hierarchy (view full)

Observable
- Wire

Index

Constructors

Properties

Methods

Constructors

constructor

new Observable<A>(_action): Observable<A>
Type Parameters
- A
Parameters
- _action: ((c) => void | Activity | (() => void))
  - - (c): void | Activity | (() => void)
    - Parameters
      c: Observer<A, unknown>
      Returns void | Activity | (() => void)
Returns Observable<A>
- Defined in index.ts:41

Properties

`Private` _action

_action: ((c) => void | Activity | (() => void))

Type declaration

- (c): void | Activity | (() => void)
- Parameters
  - c: Observer<A, unknown>
  Returns void | Activity | (() => void)

Methods

subscribe

subscribe<B>(observer): Activity
Type Parameters
- B = void
  Type returned by the incoming observer.
Parameters
- observer: Observer<A, B> | ((a) => B)
  This function will be called each time the observable publishes a value.
Returns Activity
- Defined in index.ts:50

Generated using TypeDoc