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

ConcurrentImportRunner

class ConcurrentImportRunner

Properties

protected WaitConcurrent|null $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 19
__construct(int $limit)

No description

Parameters

int $limit

at line 27
void create(callable $operation)

Run an import operation within the concurrency limit.

Parameters

callable $operation

Return Value

void

at line 65
void wait()

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

Return Value

void

at line 92
protected void throwIfFailed()

Rethrow the first import failure.

Return Value

void