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>>