Function createBlockingService

service/src/createService.ts:643–660

(
  actionNamespace: string,
  handler: EventHandler<TRequest, TNext>,
  reducerProducer?: ReducerProducer<TRequest, TNext, TError, TState>
)

 * @summary ![blocking mode](https://d2jksv3bi9fv68.cloudfront.net/rxfx/mode-blocking-sm.png)
 */
export function createBlockingService<
  TRequest,
  TNext = void,
  TError = Error,
  TState = TNext | null
>(
  actionNamespace: string,
  handler: EventHandler<TRequest, TNext>,
  reducerProducer?: ReducerProducer<TRequest, TNext, TError, TState>
): Service<TRequest, TNext, TError, TState> {
  return createServiceListener(
    actionNamespace,
    defaultBus,
    handler,
    reducerProducer,
    exhaustMap
  );
}

/**
 * Creates a Service - a concurrency-controlled wrapper around an effect, which tracks state over the effect's lifecycle events.