Skip to content

@continuum-js/frp


@continuum-js/frp / perform

Function: perform() ​

perform<A, B>(e, run): Stream<Result<unknown, B>>

Defined in: index.ts:1659

IO boundary: run an async effect per request occurrence and feed the result back into the network as a fresh occurrence (new moment). Errors are wrapped in a Result and flow as data.

Type Parameters ​

A ​

A

B ​

B

Parameters ​

e ​

Stream<A>

run ​

(a) => Promise<B>

Returns ​

Stream<Result<unknown, B>>