Class StreamConsumer

Namespace

NanoByte.Common.Streams

Assembly

NanoByte.Common.dll

Continuously reads lines from a StreamReader using a background thread while providing them to a foreground thread on demand.

public class StreamConsumer

Inheritance

object

StreamConsumer

Extension Methods

BinaryStorage.SaveBinary<T>(T, Stream)

BinaryStorage.SaveBinary<T>(T, string)

JsonStorage.SaveJson<T>(T, Stream)

JsonStorage.SaveJson<T>(T, string)

JsonStorage.ToJsonString<T>(T)

XmlStorage.SaveXml<T>(T, Stream, string?)

XmlStorage.SaveXml<T>(T, string, string?)

XmlStorage.ToXmlString<T>(T, string?)

UpdateUtils.To<T>(T, ref T, Action)

UpdateUtils.To<T>(T, ref T, ref bool)

UpdateUtils.To<T>(T, ref T, ref bool, ref bool)

UpdateUtils.To<TIn, TOut>(TIn, Func<TIn, TOut>)

ConversionUtils.ConvertToString<TType>(TType)

JsonStorage.ReparseAsJson<T>(object)

JsonStorage.ReparseAsJson<T>(object, T)

Remarks

Useful for processing StandardOutput and StandardError without risking deadlocks.

Constructors

StreamConsumer(StreamReader)

Starts reading from the stream in a background thread.

public StreamConsumer(StreamReader reader)

Parameters

reader StreamReader

The stream to read from.

Methods

ReadLine()

Returns the next pending line; null if there are no pending lines.

public string? ReadLine()

Returns

string

ToString()

Returns all buffered lines that have not been read yet.

public override string ToString()

Returns

string

WaitForEnd()

Waits for EndOfStream.

public void WaitForEnd()