1. class
  2. Hypervel
  3. \
  4. Scout
  5. \
  6. Console
  7. \
  8. ConcurrentImportRunner

ConcurrentImportRunner

class ConcurrentImportRunner

Properties

protected WaitConcurrent $concurrent
protected Throwable|null $failure

Methods

__construct(int $limit)

No description

void
create(callable $operation)

Run an import operation within the concurrency limit.

void
wait()

Wait for every active import operation and rethrow the first failure.

void
throwIfFailed()

Rethrow the first import failure.

Details

at line 18
__construct(int $limit)

No description

Parameters

int $limit

at line 26
void create(callable $operation)

Run an import operation within the concurrency limit.

Parameters

callable $operation

Return Value

void

at line 53
void wait()

Wait for every active import operation and rethrow the first failure.

Return Value

void

at line 63
protected void throwIfFailed()

Rethrow the first import failure.

Return Value

void