Configured options.
Combination of global-options GlobalUnitConfig and the options passed on instantiation.
On-demand observable events. See https://docs.activejs.dev/guides/events for more details.
An Observable to observe future values, unlike the default Observable it doesn't replay when subscribed to, rather it waits for the next value.
A counter to keep track of how many times has a Unit, System, Action or Cluster emitted.
Number of times a Unit, System, Action or Cluster has emitted.
Current value of the Action, the last dispatched value.
Creates a new Observable using the default Observable as source. Use this to conceal other aspects of a Unit, System, Action or Cluster except the Observable part.
An Observable with the value of a Unit, System, Action or Cluster.
A helper method that creates a stream by subscribing to the Observable returned by the param observableProducer callback.
Ideally the callback function creates an Observable by applying Observable.pipe.
Just know that you should catch the error in a sub-pipe (ie: do not let it propagate to the main-pipe), otherwise as usual the stream will stop working, and will not react on any further emissions.
A callback function that should return an Observable.
To manually re-emit the last emitted value again.
Converts the value to JSON string, using JSON.stringify.
Method to dispatch new value.
A value to be dispatched.
Method to dispatch new value by producing the value using the current value.
A pure function which produces a new value to be dispatched.
An Action is nothing, but an elaborate form of an RxJS Subject.
Or in other words, a simplified form of Unit.
Unlike Units, it doesn't perform any checks on dispatch.
All values pass through, just like a Subject.
See https://docs.activejs.dev/fundamentals/action for more details.