manage Method
Defines management operators for all emitter streams. These operators are applied to the streams managed by this emitter, allowing you to modify or control their behavior, such as filtering, mapping, or handling errors, without altering the type of the emitted values
@param ...operators: OperatorFunction<T, T>[]
One or more RxJS operators to apply to the emitter streams
@returns this
The instance of the emitter, allowing for method chaining
API
manage(...operators: OperatorFunction<T, T>[]): this;
Example
import {delay, filter} from 'rxjs';
import {emitter} from '@bitfiber/rx';
const launch = emitter<number>(e => e
// All streams created by this emitter will delay and filter the data
.manage(
filter(id => !!(id % 2)),
delay(100),
));