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.
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
Ideally the callback function creates an Observable by applying
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