export function tryEvent<T> (t: number, x: T, sink: Sink<T>) {
  try {
    sink.event(t, x);
  } catch (e) {
    sink.error(t, e);
  }
}

  run (sink: Sink<Location>, scheduler: Scheduler) {
    const push = (l: Location) => sink.event(scheduler.now(), l);

    const unlisten = this.history.listen(push);

    return {
      dispose () {
        unlisten();
        sink.end(scheduler.now());
      }
    };
  }

export function pushEvents<T> (buffer: any[], sink: Sink<T>) {
  for (let i = 0; i < buffer.length; ++i) {
    const {time, value} = buffer[i];
    sink.event(time, value);
  }
}

 event(t: number, x: any) {
   if (this.sink === void 0) {
     return;
   }
   this.ensureActive();
   this.sink.event(t, x);
 }

 const push = (l: Location) => sink.event(scheduler.now(), l);