in src/Apache/Ignite/Internal/Cache.php [72:93]
public function getAll(array $keys): array
{
ArgumentChecker::notEmpty($keys, 'keys');
$result = [];
$this->communicator->send(
ClientOperation::CACHE_GET_ALL,
function (MessageBuffer $payload) use ($keys)
{
$this->writeCacheInfo($payload);
$this->writeKeys($payload, $keys);
},
function (MessageBuffer $payload) use (&$result)
{
$resultCount = $payload->readInteger();
for ($i = 0; $i < $resultCount; $i++) {
array_push($result, new CacheEntry(
$this->communicator->readObject($payload, $this->keyType),
$this->communicator->readObject($payload, $this->valueType)));
}
});
return $result;
}