MCPcopy Create free account
hub / github.com/deanrad/rxfx / createBlockingEffect

Function createBlockingEffect

effect/src/createEffect.ts:339–349  ·  view source on GitHub ↗
(
  handler: EffectSource<Request, Response>,
  initialState?: TState
)

Source from the content-addressed store, hash-verified

337>(
338 handler: EffectSource<Request, Response>,
339 initialState?: TState,
340 options?: CreateEffectOptions<Request, TError>
341): EffectRunner<Request, Response, TError, TState> {
342 return createEffect(handler, concatMap, initialState, options);
343}
344
345/** Creates an Effect - A higher-order wrapper around a Promise-or-Observable-or-AsyncIterator returning function.
346 * The effect is cancelable if it returns an Observable. `createSwitchingEffect` runs in concurrency mode: "switching" aka `switchMap`.
347 * @summary ![switching mode](https://d2jksv3bi9fv68.cloudfront.net/rxfx/mode-switching-sm.png) */
348export function createSwitchingEffect<
349 Request,
350 Response = void,
351 TError extends Error = Error,
352 TState = Response

Callers 1

Calls 1

createEffectFunction · 0.85

Tested by

no test coverage detected