seaworthy.stream

stream_timeout(stream, timeout, timeout_msg=None)[source]

Iterate over items in a streaming response from the Docker client within a timeout.

Parameters:
  • stream (CancellableStream) – Stream from the Docker client to consume items from.
  • timeout – Timeout value in seconds.
  • timeout_msg – Message to raise in the exception when a timeout occurs.