example.php

<?php
require_once __DIR__ . "/vendor/autoload.php";
$collection 	= 	(new MongoDB\Client)->myDb;
$m 				= 	new MongoConcurrency\Mongo($collection);
$textData		=	[];
$options 		=	[]; 
$intData 		= 	[];
echo "Generating test data ... ";
for ($i=1; $i <= 10000  ; $i++) { 
	array_push($intData, [$i => $i]);
}
for ($i=0; $i <= 5000 ; $i++) { 
	array_push($textData, ["name" => "john"]);
}
echo "[+] \n";

$m->selectFrom("test1", [], 3, function(iterable $results) {
	echo "  [+] End select : ".sizeof($results)."\n";
});
$m->insertTo("test2", $textData, 3, function() {
	echo "  [+] End insert \n";
});
$m->updateFrom("test2", ["name" => "john"], ["name" => "alex"], 3, function(int $modified) {
	echo " [+] End update : ".$modified." \n";
});
$m->deleteFrom("test2", ["name" => "john"], 3, function(int $intDataeleted) {
	echo " [+] End delete : ".$intDataeleted."\n";
});
$m->run();