TaskFrame
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.
at line 64
void
append(string $bytes)
Append bytes received from the Task transport.
at line 74
array|null
next()
Decode the next complete Task message.
at line 108
void
finish()
Finish decoding after the transport reaches EOF.
at line 120
void
reset()
Reset all decoder state.