Skip to main content


💧EventEmitter's typesafe replacement
Go to Latest
function asyncPipe
import { asyncPipe } from "";

NOTE: Workaround until v2.0 where .pipe() will support async operators Usage example:

When the argument is a StatefulEvt: If, wile asyncOp was running, the state of the source evt have changed then the result will be discarded.

If the asyncOp complete synchronously (meaning it does not return a promise) then the result is synchronously transformed. (As with .pipe() )

More usage example in src/test/test95.ts


evt: E
asyncOp: (data: UnpackEvt<E>) => PromiseOrNot<[U] | null>


E extends StatefulReadonlyEvtLike<any> ? StatefulEvt<U | undefined> : Evt<U>