Most Operators

operators.js

// experiment operators for most.js :D
import {from, of} from 'most';
import {complement} from 'ramda';

const siphon = (pred, fn, stream) => from([stream.filter(pred).tap(fn).chain(most.empty), stream.filter(complement(pred))]).join();

const partition = (pred, stream) => from([stream.filter(pred), stream.filter(complement(pred))]); 
const partitionList = (pred, stream) => [stream.filter(pred), stream.filter(complement(pred))]; // [Streams]

siphon(x => x % 2 === 0, () => console.log('side-effect'), of(2)); // => side-effect
siphon(x => x % 2 === 0, () => console.log('side-effect'), of(3)); // 3