Stream¶

class aiodocker.stream.Message(stream, data)[source]¶

data: bytes¶: Alias for field number 1

stream: int¶: Alias for field number 0

class aiodocker.stream.Stream(docker: Docker, setup: Callable[[], Awaitable[tuple[URL, bytes | None, bool]]], timeout: aiohttp.ClientTimeout | None = None)[source]¶

async close() → None[source]¶

async read_out() → Message | None[source]¶: Read from stdout or stderr.

async write_in(data: bytes) → None[source]¶: Write into stdin.