Receive single encoded IPCMessage frame from a connection. Raise OSError if the data received is not valid.
(connection: IPCBase)
| 472 | |
| 473 | |
| 474 | def receive(connection: IPCBase) -> ReadBuffer: |
| 475 | """Receive single encoded IPCMessage frame from a connection. |
| 476 | |
| 477 | Raise OSError if the data received is not valid. |
| 478 | """ |
| 479 | bdata = connection.read_bytes() |
| 480 | if not bdata: |
| 481 | raise OSError("No data received") |
| 482 | return ReadBuffer(bdata) |
| 483 | |
| 484 | |
| 485 | class IPCMessage: |
no test coverage detected
searching dependent graphs…