LevitTaskEngine constructor

LevitTaskEngine({
  1. required int maxConcurrent,
  2. LevitTaskCacheProvider? cacheProvider,
  3. void onTaskError(
    1. Object error,
    2. StackTrace stackTrace
    )?,
  4. void onTaskEvent(
    1. LevitTaskEvent event
    )?,
  5. String ownerPath = '?',
})

Creates a task engine with maxConcurrent workers.

Implementation

LevitTaskEngine({
  required int maxConcurrent,
  LevitTaskCacheProvider? cacheProvider,
  this.onTaskError,
  this.onTaskEvent,
  this.ownerPath = '?',
})  : _maxConcurrent = maxConcurrent,
      cacheProvider = cacheProvider ?? InMemoryTaskCacheProvider() {
  if (maxConcurrent < 1) {
    throw RangeError.range(maxConcurrent, 1, null, 'maxConcurrent');
  }
}