Properties

$client

$client : 

Type

$requests

$requests : 

Type

$deadlines

$deadlines : 

Type

$results

$results : 

Type

$stream

$stream : 

Type

$async

$async : 

Type

Methods

__construct()

__construct(\Client  $client,   $async) 

Parameters

\Client $client
$async

__destruct()

__destruct() 

loop()

loop() 

asyncSendAndReceive()

asyncSendAndReceive(  $buffer, \stdClass  $context) 

Parameters

$buffer
\stdClass $context

syncSendAndReceive()

syncSendAndReceive(  $buffer, \stdClass  $context) 

Parameters

$buffer
\stdClass $context

sendAndReceive()

sendAndReceive(  $buffer, \stdClass  $context) 

Parameters

$buffer
\stdClass $context

appendHeader()

appendHeader(  $request) 

Parameters

$request

createRequest()

createRequest(  $index,   $request) 

Parameters

$index
$request

afterWrite()

afterWrite(  $request,   $stream,   $o) 

Parameters

$request
$stream
$o

getBodyLength()

getBodyLength(  $stream) 

Parameters

$stream

asyncReadError()

asyncReadError(  $o,   $stream,   $index) 

Parameters

$o
$stream
$index

getResponse()

getResponse(  $stream,   $o) 

Parameters

$stream
$o

afterRead()

afterRead(  $stream,   $o,   $response) 

Parameters

$stream
$o
$response

getLastError()

getLastError(  $error) 

Parameters

$error

removeStream()

removeStream(  $stream,   $pool) 

Parameters

$stream
$pool

readHeader()

readHeader(  $stream,   $n) 

Parameters

$stream
$n

free()

free(  $o,   $index) 

Parameters

$o
$index

asyncWrite()

asyncWrite(  $stream,   $o) 

Parameters

$stream
$o

asyncRead()

asyncRead(  $stream,   $o) 

Parameters

$stream
$o

removeStreamById()

removeStreamById(  $stream_id,   $pool) 

Parameters

$stream_id
$pool

closeTimeoutStream()

closeTimeoutStream(  $o,   $index) 

Parameters

$o
$index

checkTimeout()

checkTimeout(  $o) 

Parameters

$o

createPool()

createPool(  $client,   $o) 

Parameters

$client
$o

write()

write(  $stream,   $request) 

Parameters

$stream
$request

read()

read(  $stream) 

Parameters

$stream