class TaskFrame

internal  
 

Encode and incrementally decode Task transport frames.

Constants

private HEADER_LENGTH

private COMPACTION_THRESHOLD

private TYPES

Methods

static string
encode(string|null $type, string $payload)

Encode a Task message.

void
append(string $bytes)

Append bytes received from the Task transport.

array|null
next()

Decode the next complete Task message.

void
finish()

Finish decoding after the transport reaches EOF.

void
reset()

Reset all decoder state.

Details

at line 43
static string encode(string|null $type, string $payload)

Encode a Task message.

Parameters

string|null $type
string $payload

Return Value

string

at line 64
void append(string $bytes)

Append bytes received from the Task transport.

Parameters

string $bytes

Return Value

void

at line 74
array|null next()

Decode the next complete Task message.

Return Value

array|null

at line 108
void finish()

Finish decoding after the transport reaches EOF.

Return Value

void

at line 120
void reset()

Reset all decoder state.

Return Value

void