Emits when the running context has shifted to a new value. Emits null when there is no running context.
Stream of context results that will be emitted as each action finishes (either with a result or with an error)
Fallback command options that will be used when not supplied in one of the enqueueing methods.
Observable that will emit when abort() is called with either ALL or ACTIVE.
Currently running command, if one exists. Returns null if no command is running.
Returns true if this queue has been destroyed.
Observable that will emit when abort() is called with either ALL or PENDING.
Used to kill queued and active command contexts. Run this with type ALL as a last stage cleanup option when resetting state.
Add an action to the queue for pending execution. Does not execute until all preceding tasks have completed.
Generates a configuration instance by filling in missing properties from the given config with known ones from the root config.
Tear-down option that cleans up the internal rxjs refs. CommandQueue references should be disposed of after this is called.
Special flavor of add() whose value is a pending observable. The inner observable will not be created until all preceding tasks have completed.
Generated using TypeDoc
A stupidly simple queueing mechanism that guarantees order of execution, based on a first-come-first-serve precedent.