function tryDispose<T> (time: number, disposable: Disposable<T>, sink: Sink<T>) {
  try {
    disposable.dispose()
  } catch (e) {
    sink.error(time, e)
  }
}

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

 complete (value?: T) {
   this.sink.end(this.scheduler.now(), value)
 }

 error (err: Error) {
   this.sink.error(this.scheduler.now(), err)
 }

 next (value: T) {
   this.sink.event(this.scheduler.now(), value)
 }

 end (time: number, value?: IndexedValue<T>) {
   tryDispose(time, this.disposables[value.index], this.sink)
   if (--this.activeCount === 0) {
     this.sink.end(time, value.value)
   }
 }

 error (time: number, err: Error) {
   this.sink.error(time, err)
 }

 event (time: number, value: IndexedValue<T>) {
   this.sink.event(time, value.value)
 }

 }).then(() => {
   sink.end(scheduler.now(), void 0)
 })