muqsit / asynciterator Goto Github PK

AsyncIterator::forEach(new ArrayIterator($array))
->as(function(int $key, string $value) : bool{
})->then(function() : void{
	// this callback gets triggered
});

AsyncIterator::forEach(new ArrayIterator($array))
->as(function(int $key, string $value) : bool{
})->then(function() : void{
	// this callback does not get triggered
})->cancel();

AsyncIterator::forEach(new ArrayIterator($array))
->as(function(int $key, string $value) : bool{ return $boolean; })
->onCompletion(function() : void{ /* iteration completed successfully */ })
->onInterruption(function() : void{ /* iteration was interrupted */ });

AsyncIterator::forEach(new ArrayIterator([1, 2, 3]))
->as(function(int $key, int $value) : AsyncForeachResult{
	echo $value, ", ";
	return AsyncForeachResult::CONTINUE();
})
->onCompletion(function() : void{ echo "Completed"; })
->onInterruption(function() : void{ echo "Interrupted"; });
// OUTPUT:
// 1, 2, 3, Completed

AsyncIterator::forEach(new ArrayIterator([1, 2, 3]))
->as(function(int $key, int $value) : AsyncForeachResult{
	echo $value, ", ";
	if($value <= 2){
		return AsyncForeachResult::CONTINUE();
	}else{
		return AsyncForeachResult::INTERRUPT();
	}
})
->onCompletion(function() : void{ echo "Completed"; })
->onInterruption(function() : void{ echo "Interrupted"; });
// OUTPUT:
// 1, 2, Interrupted

AsyncIterator::forEach(new ArrayIterator([1, 2, 3]))
->as(function(int $key, int $value) : AsyncForeachResult{
	echo $value, ", ";
	if($value <= 2){
		return AsyncForeachResult::CONTINUE();
	}else{
		return AsyncForeachResult::CANCEL();
	}
})
->onCompletion(function() : void{ echo "Completed"; })
->onInterruption(function() : void{ echo "Interrupted"; });
// OUTPUT:
// 1, 2