TracomPersistentQueue constructor

TracomPersistentQueue(
  1. String filename, {
  2. int flushAt = 100,
  3. Duration flushTimeout = const Duration(minutes: 5),
  4. required int maxLength,
  5. required String nickname,
  6. required FutureOr onFlush(
    1. List
    ),
})

Implementation

factory TracomPersistentQueue(String filename,
    {int flushAt = 100,
      Duration flushTimeout = const Duration(minutes: 5),
      required int maxLength,
      required String nickname,
      required FutureOr Function(List) onFlush}) {
  _configs[filename] = _Config(
      flushAt: flushAt,
      flushTimeout: flushTimeout,
      maxLength: maxLength ?? flushAt * 5,
      onFlush: onFlush);

  if (queues.containsKey(filename)) {
    return queues['filename'];
  }

  return queues[filename] =
      TracomPersistentQueue._internal(filename, nickname ?? filename);
}