Observable
Direct Subclass:
Indirect Subclass:
Example:
let ready = new Observable;
ready.subscribe(data => console.log("Received:", data));
ready.emit("Foo");
//> Received: FooMethod Summary
| Public Methods | ||
| public |
Invoke each registered listener with |
|
| public |
filter(predicate: function(value: Any): boolean): Observable |
|
| public |
hasSubscribed(listener: function): boolean True if |
|
| public |
map(mapper: function(value: Any): Any): Observable |
|
| public |
|
|
| public |
subscribe(listener: function): Subscription Register listener |
|
| public |
unsubscribe(listener: function) Unregister listener |
|
Public Methods
public emit(value: Any) source
Invoke each registered listener with value.
Params:
| Name | Type | Attribute | Description |
| value | Any | argument will be passed to listeners |
public filter(predicate: function(value: Any): boolean): Observable source
Example:
let numbers = new Observable;
let even = numbers.filter(v => v % 2 === 0);
numbers.subscribe(v => console.log("Any:", v))
even.subscribe(v => console.log("Even:", v));
numbers.emit(1);
//> Any: 1
numbers.emit(2);
//> Any: 2
//> Even: 2public hasSubscribed(listener: function): boolean source
True if listener has subscribed to this observable
Params:
| Name | Type | Attribute | Description |
| listener | function |
public map(mapper: function(value: Any): Any): Observable source
Example:
let x = new Observable;
x.map(v => v * 2).subscribe(v => console.log("Value:", v));
x.emit(10);
//> Value: 20public reduce(accumulator: Any, reducer: function(accumulator: Any, value: Any): Any): ObservableState source
Example:
let emitter = new Observable;
let sum = emitter.reduce(0, (a, v) => a + v);
sum.subscribe(s => console.log(s));
emitter.emit(10);
//> 10
emitter.emit(15);
//> 25public subscribe(listener: function): Subscription source
Register listener
Params:
| Name | Type | Attribute | Description |
| listener | function |
Throw:
if |