Netcore

Pipe API

Pipe

Constructor

Pipe(
    recv_function: Callable[[Optional[int]], bytes],
    send_function: Callable[[bytes], None]
)

Properties

Methods

def 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