pipeRealtime

Pipes a stream to another while keeping the latency within the specified threshold.

void
pipeRealtime
(
OutputStream
ConnectionStream
)
(
OutputStream destination
,
ConnectionStream source
,
ulong nbytes = 0
,
Duration max_latency = 0.seconds
)
if (
isOutputStream!OutputStream &&
isConnectionStream!ConnectionStream
)

Parameters

destination OutputStream

The destination stram to pipe into

source ConnectionStream

The source stream to read data from

nbytes ulong

Number of bytes to pipe through. The default of zero means to pipe the whole input stream.

max_latency Duration

The maximum time before data is flushed to destination. The default value of 0 s will flush after each chunk of data read from source.

See Also

OutputStream.write

Meta