fLimit function

FLimit fLimit(
  1. int concurrency, {
  2. QueueStrategy queueStrategy = QueueStrategy.fifo,
})

Create a concurrency limiter

Convenience function that creates an FLimit instance.

concurrency must be >= 1. queueStrategy determines task execution order. Defaults to QueueStrategy.fifo.

Example:

final limit = fLimit(2);

await limit(() async {
  print('Running with concurrency limit');
});

// With custom strategy
final priority = fLimit(1, queueStrategy: QueueStrategy.priority);
priority(() async => taskA(), priority: 10);
priority(() async => taskB(), priority: 1);
// taskA runs first

Implementation

FLimit fLimit(int concurrency,
    {QueueStrategy queueStrategy = QueueStrategy.fifo}) {
  return FLimit(concurrency, queueStrategy: queueStrategy);
}