cycle-fetcher-driver.js

import { Rx } from '@cycle/core'
import Fetcher from 'stackable-fetcher'

export default function makeFetcherDriver(fetcher = new Fetcher()) {
  return (request$) => {
    return request$.map((request) => {
      return Rx.Observable.fromPromise(
        fetcher[request.method.toLowerCase()](
          request.url,
          request.parameters,
          request.headers
        )
      ).do((response$) => {
        response$.request = request;
      });
    }).share();
  };
}