RxJS Streams Visualizer

Watch how data flows through an RxJS observable pipeline. See values emitted from a source, transformed by operators (`map`), and filtered (`filter`) before reaching the subscriber.

source$

map(x → x * 2)

filter(x → x > 10)

// The code behind the pipeline

const

source$ = new Subject();

source$.pipe(
  map(x => x * 2),
  filter(x => x > 10)
).subscribe(val => {
  console.log(val);
});

Subscriber Output

Waiting...

Operator Stream Log

No activity yet. Click Emit Next Value.