Function createQueueingService

service/src/createService.ts:461–478

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

 * @summary ![queueing mode](https://d2jksv3bi9fv68.cloudfront.net/rxfx/mode-queueing-sm.png)
 */
export function createQueueingService<
  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,
    concatMap
  );
}
/**
 * Creates a Service - a concurrency-controlled wrapper around an effect, which tracks state over the effect's lifecycle events.
 * The effect can be a Promise-or-Observable-or-AsyncIterator returning function, and is cancelable if Observable.