使用 Guzzle 6 创建异步 json 请求池以发送到 API 端点的正确方法是什么？

我的目标是使用Guzzle 6创建一个 PUT json 数据的异步请求池。然后监视每个 $promise 成功/失败。

为了与我的 POOL 代码示例进行比较，以下对 $client->request() 的单个请求将第三个参数转换为编码的 json，然后添加 Content-type:application/json。**

$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);

使用文档中的并发请求示例，用于创建异步请求池使用 new Request()，我希望可以使用相同的参数（方法、url 端点、json 标志），如上面的单个 $client->request() 示例所示。然而，yield new Request()不处理第三个 json 参数，例如$client->request(). 从我的 Pool 代码中调用以正确设置 json 和内容类型的正确 Guzzle 函数是什么？或者是否有更好的方法来创建大量异步请求并监视其结果？

池代码示例：

$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.

希望其他人会介入并让我知道是否有更正确的方法来实现我的目标，但是在 Guzzle 的底层查看之后，我意识到 new Request() 的第三个参数正在寻找标头信息，而第四个参数正在寻找标头信息。参数正在寻找实体。所以下面的代码可以使用 Pool 来工作：

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

Also in docs for Psr7\Request