| 
<?phprequire_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();
 |