import { subchain } from "https://deno.land/x/stream_observables@v1.3/transforms/mod.ts";
Returns a Transform that applies f to the observable.
Examples
subchain() can be used to create logical groups in a longer chain
or to make parts of a chain reusable.
subchain() can be used to create logical groups in a longer chain
or to make parts of a chain reusable.
ows
.fromEvent(button, "click")
.pipeThrough(
ows.subchain(o =>
o
.pipeThrough(ows.map(() => fetch("/stockData")))
.pipeThrough(ows.map(r => r.json()))
.pipeThrough(ows.filter(data => data.tags.contains(importTag)))
)
)
.pipeTo(
ows.discard(data => {
// ...
})
);