Каков правильный способ использования Guzzle 6 для создания пула асинхронных запросов json для отправки конечным точкам API?

Моя цель – использовать Guzzle 6 для создания пула асинхронных запросов, которые PUT json data. Затем отслеживайте каждый успешный результат / неудачу.

Для сравнения с моим примером кода POOL следующий одиночный запрос к $ client-> request () преобразует третий параметр в кодированный json, а затем добавляет Content-type: application / json. **

• PHP добавляет ключи для декодирования, а затем кодирует данные JSON
• Как добавить заголовки в электронную почту в Laravel 5.1
• file_exists () возвращает false, даже если файл существует (удаленный URL)
• Переключить идентификационные номера двух строк в MySql
• Генератор HTML: конвертируйте HTML в PlainText и помещайте в TextBox с помощью PHP

$client = new Client([ 'base_uri' => BASE_URL . 'test/async/', // Base URI is used with relative requests 'timeout' => 0, // 0 no timeout for operations and watching Promises ]); $response = $client->request('PUT', 'cool', ['json' => ['foo' => 'bar']]); 

В конечной точке получающего API я могу прочитать json из одного запроса выше, выполнив следующее:

 $json = file_get_contents('php://input'); $json = json_decode($json, true); 

Используя пример параллельных запросов в документах, для создания пула асинхронных запросов с использованием нового Request () я надеялся, что одни и те же параметры (метод, конечная точка url, json flag) могут использоваться, как в одиночном запросе $ client-> ) пример выше. Однако yield new Request() не обрабатывает третий параметр json, например $client->request() . Какова правильная функция Guzzle для вызова из моего кода пула, чтобы правильно установить json и content-type? Или есть лучший способ создать большой пул асинхронных запросов и контролировать их результат?

Пример кода POOL:

 $this->asyncRequests = [ [ 'endpoint' => 'cool' ], [ 'endpoint' => 'awesome' ], [ 'endpoint' => 'crazy' ], [ 'endpoint' => 'weird' ] ]; $client = new Client([ 'base_uri' => BASE_URL, // Base URI is used with relative requests 'timeout' => 0 // 0 no timeout for operations and watching Promises ]); $requests = function ($asyncRequests) { $uri = BASE_URL . 'test/async/'; foreach ($asyncRequests as $key => $data) { yield new Request('PUT', "{$uri}{$data['endpoint']}", ['json' => ['foo' => 'bar']]); } }; $pool = new Pool($client, $requests($this->asyncRequests), [ 'concurrency' => 10, 'fulfilled' => function ($response, $index) { $this->handleSuccessPromises($response, $index); }, 'rejected' => function ($reason, $index) { $this->handleFailurePromises($reason, $index); }, ]); $promise = $pool->promise(); // Initiate the transfers and create a promise $promise->wait(); // Force the pool of requests to complete. 

 foreach ($syncRequests as $key => $headers) { yield new Request('PUT', "{$uri}{$headers['endpoint']}", ['Content-type' => 'application/json'], json_encode(['json' => ['nonce' => $headers['json']]])); }