@phylum/rxjs

RxJS Integration

Installation

npm i @phylum/pipeline @phylum/rxjs rxjs

Creating observables

Pipeline tasks can be wrapped into observables that push objects with an error or with a value property representing the task result.

import { createObservable } from '@phylum/rxjs';

const task = new Task(async () => {
	return 'Hello World!';
})

const observable = createObservable(task);

observable.subscribe(({ value, error }) => {
	if (error) {
		console.error(error);
	} else {
		console.log(value);
	}
});

Creating tasks

Observables can be wrapped into tasks that emit results for each value or error that is pushed by the observable.

import { createTask } from '@phylum/rxjs';

const observable = new Observable(subscriber => {
	subscriber.next('Hello World!');
})

const task = createTask(observable);

new Task(async t => {
	console.log(await t.use(task));
})