Class MessageWriter

Namespace

Bonsai.Harp

Assembly

Bonsai.Harp.dll

Represents an operator that writes each Harp message in the sequence to a raw binary file.

public class MessageWriter : FileSink<HarpMessage, BinaryWriter>

Inheritance

object

FileSink

FileSink<HarpMessage, BinaryWriter>

MessageWriter

Inherited Members

FileSink<HarpMessage, BinaryWriter>.CreateWriter(string, HarpMessage)

FileSink<HarpMessage, BinaryWriter>.Write(BinaryWriter, HarpMessage)

FileSink<HarpMessage, BinaryWriter>.Process<TElement>(IObservable<TElement>, Func<TElement, HarpMessage>)

FileSink<HarpMessage, BinaryWriter>.Process<TElement>(IObservable<TElement>, Func<TElement, HarpMessage>, string)

FileSink<HarpMessage, BinaryWriter>.Process(IObservable<HarpMessage>)

FileSink.FileName

FileSink.Suffix

FileSink.Buffered

FileSink.Overwrite

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Properties

FilterType

Gets or sets a value specifying how the message filter will use the matching criteria.

MessageType

Gets or sets a value specifying the expected message type. If no value is specified, all messages will be accepted.

Methods

CreateWriter(string, HarpMessage)

Creates a binary writer over the specified file that will be responsible for handling the input elements.

Process(IObservable<IGroupedObservable<int, HarpMessage>>)

Writes each Harp message in the sequence of observable groups to the corresponding binary file, where the name of each file is generated from the common group register address.

Process(IObservable<IGroupedObservable<Type, HarpMessage>>)

Writes each Harp message in the sequence of observable groups to the corresponding binary file, where the name of each file is generated from the common group register name.

Write(BinaryWriter, HarpMessage)

Writes a new Harp message to the raw binary output stream.