How to use the @most/scheduler.asap function in @most/scheduler

To help you get started, we’ve selected a few @most/scheduler examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

github mostjs / core / packages / core / src / source / empty.ts View on Github external
run(sink: Sink, scheduler: Scheduler): Disposable {
    return asap(propagateEndTask(sink), scheduler)
  }
}
github mostjs / core / packages / core / src / combinator / errors.ts View on Github external
run(sink: Sink, scheduler: Scheduler): Disposable {
    return asap(propagateErrorTask(this.value, sink), scheduler)
  }
}
github mostjs / core / packages / core / src / combinator / scan.ts View on Github external
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>

@most/scheduler

Reactive programming with lean, functions-only, curried, tree-shakeable API

MIT
Latest version published 4 years ago

Package Health Score

54 / 100
Full package analysis