Arcane.Async
Promessas, filas e agendamento.
exemplo
adopt Arcane.Async as Async
// Promessas e agendamento
tarefa := Async.promise(lambda: 42)
out Async.resolve(tarefa)Funções (46)#
| Assinatura |
|---|
all(promises) |
any(promises) |
batch(fn) |
buffer_op(size) |
catch(promise, callback) |
channel(buffer_size=0) |
combine_latest(*observables) |
computed(signals, fn) |
debounce_op(ms) |
delay(ms, fn=None) |
distinct_op() |
effect(signals, fn) |
emit(emitter, event, *data) |
emit_event(emitter, event, *data) |
emitter() |
event_emitter() |
filter_op(fn) |
from_list(lst) |
interval(ms, count=10) |
map_op(fn) |
merge(*observables) |
observable(producer=None) |
of(*values) |
off(emitter, event, callback=None) |
on(emitter, event, callback) |
once_event(emitter, event, callback) |
parallel(*fns) |
pipe_stream(observable, *operators) |
promise(executor) |
race(promises) |
receive(ch) |
reject(error) |
resolve(value) |
retry_task(fn, max_retries=3, delay_ms=100) |
scan_op(fn, initial) |
send(ch, value) |
sequential(*fns) |
settled(promises) |
signal(initial_value) |
skip_op(n) |
subject() |
subscribe(observable, callback) |
take_op(n) |
task(fn) |
then(promise, callback) |
timeout(ms, fn) |