Send data to a connection encoded and framed. The data must be a non-abstract IPCMessage. We assume that a single send call is a single frame to be sent.
(connection: IPCBase, data: IPCMessage)
| 461 | |
| 462 | |
| 463 | def send(connection: IPCBase, data: IPCMessage) -> None: |
| 464 | """Send data to a connection encoded and framed. |
| 465 | |
| 466 | The data must be a non-abstract IPCMessage. We assume that a single send call is a |
| 467 | single frame to be sent. |
| 468 | """ |
| 469 | buf = WriteBuffer() |
| 470 | data.write(buf) |
| 471 | connection.write_bytes(buf.getvalue()) |
| 472 | |
| 473 | |
| 474 | def receive(connection: IPCBase) -> ReadBuffer: |
no test coverage detected
searching dependent graphs…