memoryBrokerFactory function

StemBrokerFactory memoryBrokerFactory({
  1. String namespace = 'stem',
  2. Duration defaultVisibilityTimeout = const Duration(seconds: 30),
})

Creates a StemBrokerFactory backed by InMemoryBroker.

Implementation

StemBrokerFactory memoryBrokerFactory({
  String namespace = 'stem',
  Duration defaultVisibilityTimeout = const Duration(seconds: 30),
}) {
  return StemBrokerFactory(
    create: () async => InMemoryBroker(
      namespace: namespace,
      defaultVisibilityTimeout: defaultVisibilityTimeout,
    ),
    dispose: (broker) async {
      if (broker is InMemoryBroker) {
        broker.dispose();
        return;
      }
      await broker.close();
    },
  );
}