acdlite/recompose

let _config = {
  fromESObservable: null,
  toESObservable: null,
}

const configureObservable = c => {
  _config = c
}

export const config = {
  fromESObservable: observable =>
    typeof _config.fromESObservable === 'function'
      ? _config.fromESObservable(observable)
      : observable,
  toESObservable: stream =>
    typeof _config.toESObservable === 'function'
      ? _config.toESObservable(stream)
      : stream,
}

export default configureObservable