pluckSwitch.js

// @mariuslundgard
// The component
import {pluckSwitch} from './stream-helpers'

function main (sources) {
  const sinks$ = NodeComponent({...sources})
  // etc.

  return {
    DOM: pluckSwitch('DOM', sinks$),
    midi$: pluckSwitch('midi$', sinks$)
    // etc.
  }
}
// stream-helpers.js
export function pluckSwitch (key, stream) {
  return stream
    .filter((s) => s[key])
    .map((s) => s[key])
    .switch()
}



//// fixed example


import {pluckSwitch} from './stream-helpers'

function main (sources) {
  const sinks$ = sources.location$.map((location) => {
    // do route matching here
    return RouteComponent({
      ...sources,
      location$: Observable.of(location)
    })
  })

  return {
    DOM: pluckSwitch('DOM', sinks$),
    location$: pluckSwitch('location$', sinks$)
  }
}

Also

import {Observable as O} from 'rx';

// This driver captures global events
// and provides them as Observable
export const globalEventDriver = () => {
  return {
    events: (eventName) => {
      return O.fromEventPattern(
        (h) => {
          document.addEventListener(eventName, h, true);
        },
        (h) => {
          document.removeEventListener(eventName, h, true);
        }
      );
    },
  };
};