docs: function foo(obj){
      let fn = obj.fn;
      let err = obj.err;
      return next => Sink.of(
          (value, time, scheduler, task) => fn(value, time, next, scheduler, task),
          (e, time, scheduler, task) => err(e, time, next, scheduler, task));
  }