CurlStreamingHandler
class CurlStreamingHandler
| internal |
Deliver streaming responses without sharing an active cURL multi handle.
Constants
| MAX_IDLE_CONNECTIONS |
|
Properties
| protected CurlFactoryInterface | $factory | ||
| protected CurlStreamingConnection> | $idleConnections |
Methods
Create a streaming handler with optional named-connection retention.
Add coroutine streaming while retaining the caller's fallback handler.
Determine whether the current execution can use native streaming.
Start a transfer and return its response without draining its body.
Obtain an exclusive transport for the request's route without sharing another proxy's tunnel.
Retain an idle transport after its request has been detached.
Normalize a nonnegative request timeout in seconds.
Details
at line 46
__construct(array $options = [], int $maxIdleConnections = 0)
Create a streaming handler with optional named-connection retention.
at line 59
static Closure
wrap(callable $fallback, array $options = [], int $maxIdleConnections = 0)
Add coroutine streaming while retaining the caller's fallback handler.
at line 77
static bool
supports(array $options)
Determine whether the current execution can use native streaming.
at line 91
PromiseInterface
__invoke(RequestInterface $request, array $options)
Start a transfer and return its response without draining its body.
at line 173
protected CurlStreamingConnection
acquire(EasyHandle $easy)
Obtain an exclusive transport for the request's route without sharing another proxy's tunnel.
at line 197
void
release(CurlStreamingConnection $connection)
Retain an idle transport after its request has been detached.
at line 213
protected float
timeout(mixed $value, string $name)
Normalize a nonnegative request timeout in seconds.