Show:

An Observable is a stream for events set discretely in time, as opposed to continuously. It emits appropriate start and end events upon calling the set method.

Constructor

Streams.Observable

(
  • value
)
private

Parameters:

  • value Number, String, Array, Object

    Value

Item Index

Methods

filter

(
  • filterFn
)
SimpleStream

Inherited from Streams.SimpleStream:

Filter converts the current stream into a new stream that only emits if the filter condition is satisfied. The filter function should return a Boolean value.

Parameters:

  • filterFn Function
    Function to filter event payload

Returns:

SimpleStream: stream Filtered stream

get

() Number, String, Array, Object

Getter for the provided value.

Returns:

Number, String, Array, Object:

map

(
  • mapperFn
)
SimpleStream

Inherited from Streams.SimpleStream:

Map converts the current stream into a new stream with a modified (mapped) data payload.

Parameters:

  • mapperFn Function
    Function to map event payload

Returns:

SimpleStream: stream Mapped stream

pluck

(
  • key
)
SimpleStream

Inherited from Streams.SimpleStream:

Pluck is an opinionated mapper. It projects a Stream onto one of its return values. Useful if a Stream returns an array or object.

Parameters:

Returns:

SimpleStream: stream Plucked stream

set

(
  • value
)

Setter for the provided value.

Parameters:

  • value Number, String, Array, Object

    Value

split

(
  • splitterFn
)

Inherited from Streams.SimpleStream:

Split maps one of several streams based on custom logic. The splitter function should return an EventEmitter type.

Parameters: