Pipe(
recv_function: Callable[[Optional[int]], bytes],
send_function: Callable[[bytes], None]
)
is_data
-> bool: Check if data availabledef send(data: bytes, info: dict = {}) -> None
Send data with optional info
def recv() -> tuple[bytes, dict]
Receive data and info
def create_mission(
data: bytes,
info: dict = {},
extension: Optional[str] = None,
buff: int = 4096
) -> str
Create send mission
def start() -> None
Start pipe threads