danog/TelegramApiServer
1
0
Fork 0
mirror of https://github.com/danog/TelegramApiServer.git synced 2024-11-30 04:19:13 +01:00
Code Issues Projects Releases Wiki Activity

Feat: new group for requests

Browse Source
This commit is contained in:
Alexander Pankratov 2024-07-14 21:53:10 +02:00
parent 2374b64e90
commit 4c637fee7f
1 changed files with 15 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/Controllers/ApiController.php
View File

@ -2,12 +2,14 @@
namespace TelegramApiServer\Controllers;
use Amp\DeferredFuture;
use Exception;
use TelegramApiServer\Client;
use TelegramApiServer\Config;
use TelegramApiServer\Logger;
use function Amp\async;
use function Amp\delay;
use function Amp\Future\await;
use function Amp\Future\awaitAll;
final class ApiController extends AbstractApiController
@ -39,18 +41,22 @@ final class ApiController extends AbstractApiController
}
//GROUP REQUESTS IN BULKS
static $futures = [];
/** @var ?DeferredFuture $lock */
static $lock = null;
$futures[] = $future = async($this->callApiCommon(...), $madelineProto);
delay($this->waitNextTick());
if ($futures) {
awaitAll($futures);
Logger::getInstance()->notice("Executed bulk requests:" . count($futures));
$futures = [];
if (!$lock) {
try {
$lock = new DeferredFuture();
delay($this->waitNextTick());
$lock->complete();
} finally {
$lock = null;
}
} else {
$lock->getFuture()->await();
}
return $future->await();
return $this->callApiCommon($madelineProto);
}
/**