import { type ParallelRet, 
parallel, 
safe, 
raceMap, 
request, 
json
} from "@effection-contrib/fx"

@effection-contrib/fx

A collection of utility functions to streamline asynchronous workflows. These functions were originally part of the starfx project and have been adapted for use with the Effection framework.

API

interface ParallelRet<T> extends Computation<Result<T>[]> {

sequence: Channel<Result<T>, void>;
immediate: Channel<Result<T>, void>;

}

@effection-contrib/fx

API

interface ParallelRet<T> extends Computation<Result<T>[]> {

function parallel(operations: Callable<T>[]):

function* safe(operator: Callable<T>): Operation<Result<T>>

function raceMap(opMap: OpMap): Operation<>

function* request(url: string | URL | Request, opts?: RequestInit):

function* json(response: Response):