Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
run(sink: Sink, scheduler: Scheduler): Disposable {
return asap(propagateEndTask(sink), scheduler)
}
}
run(sink: Sink, scheduler: Scheduler): Disposable {
return asap(propagateErrorTask(this.value, sink), scheduler)
}
}
run(sink: Sink<b>, scheduler: Scheduler): Disposable {
const d1 = asap(propagateEventTask(this.value, sink), scheduler)
const d2 = this.source.run(new ScanSink(this.f, this.value, sink), scheduler)
return disposeBoth(d1, d2)
}
}</b>