vibe.stream.counting

Wrapper streams which count the number of bytes or limit the stream based on the number of transferred bytes.

Public Imports

vibe.core.stream
public import vibe.core.stream;
Undocumented in source.

Members

Classes

CountingInputStream
class CountingInputStream

Wraps an existing input stream, counting the bytes that are written.

CountingOutputStream
class CountingOutputStream

Wraps an existing output stream, counting the bytes that are written.

EndCallbackInputStream
class EndCallbackInputStream

Wraps an input stream and calls the given delegate once the stream is empty.

LimitException
class LimitException
Undocumented in source.
LimitedInputStream
class LimitedInputStream

Wraps an existing stream, limiting the amount of data that can be read.

Functions

createCountingOutputStream
CountingOutputStream createCountingOutputStream(OutputStream output, ulong byte_limit)

Creates a proxy stream that counts the number of bytes written.

createCountingOutputStreamFL
FreeListRef!CountingOutputStream createCountingOutputStreamFL(OutputStream output, ulong byte_limit)

private

createEndCallbackInputStream
EndCallbackInputStream createEndCallbackInputStream(InputStream input, void delegate() @(safe) callback)

Creates a stream that fires a callback once the end of the underlying input stream is reached.

createEndCallbackInputStreamFL
FreeListRef!EndCallbackInputStream createEndCallbackInputStreamFL(InputStream input, void delegate() @(safe) callback)

private

createLimitedInputStream
LimitedInputStream createLimitedInputStream(InputStream stream, ulong byte_limit, bool silent_limit)

Constructs a limited stream from an existing input stream.

createLimitedInputStreamFL
FreeListRef!LimitedInputStream createLimitedInputStreamFL(InputStream stream, ulong byte_limit, bool silent_limit)

private

Meta

License

Subject to the terms of the MIT license, as written in the included LICENSE.txt file.

Authors

Sönke Ludwig