tungv

amqp-exchange

simple interface to connect to an exchange to publish and to subscribe from a queue with binding

@async-generator/buffer-time-count

buffer a generator with a timespan or a maximum buffer length

@async-generator/concurrent

execute tasks concurrently

@async-generator/emitter-on

ponyfill for EventEmitter.on in node 13+

@async-generator/interval

generate integers after an constant amount of time

@async-generator/interval-with-reset

generate integers after an constant amount of time and a function to reset clock

@async-generator/map

like Array#map but for async generator

@async-generator/merge

merge multiple async generator into one

@async-generator/merge-race

merge multiple async generator into one and stop with the first one to stop

@async-generator/subject

create an async iterator with functions to feed value into and end it