Class ObservableExtensions

Namespace

Bonsai.Harp

Assembly

Bonsai.Harp.dll

Provides a set of static extension methods to aid in writing queries over observable Harp message sequences.

public static class ObservableExtensions

Inheritance

object

ObservableExtensions

Inherited Members

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Methods

Event(IObservable<HarpMessage>, int)

Filters the elements of an observable sequence of Harp event messages based on their address.

public static IObservable<HarpMessage> Event(this IObservable<HarpMessage> source, int address)

Parameters

source IObservable<HarpMessage>

The observable sequence whose event messages to filter.

address int

The address to test for a match.

Returns

IObservable<HarpMessage>

An observable sequence that contains event messages from the input sequence that match the specified address.

Event(IObservable<HarpMessage>, int, bool)

Filters the elements of an observable sequence of Harp event messages based on their address.

public static IObservable<HarpMessage> Event(this IObservable<HarpMessage> source, int address, bool allowErrors)

Parameters

source IObservable<HarpMessage>

The observable sequence whose event messages to filter.

address int

The address to test for a match.

allowErrors bool

true to allow error messages in the filter; otherwise, false.

Returns

IObservable<HarpMessage>

An observable sequence that contains event messages from the input sequence that match the specified address.

Where(IObservable<HarpMessage>, MessageType)

Filters the elements of an observable sequence of Harp messages based on their message type.

public static IObservable<HarpMessage> Where(this IObservable<HarpMessage> source, MessageType messageType)

Parameters

source IObservable<HarpMessage>

The observable sequence whose messages to filter.

messageType MessageType

The message type to test for a match.

Returns

IObservable<HarpMessage>

An observable sequence that contains messages from the input sequence that match the specified messageType.

Where(IObservable<HarpMessage>, MessageType, bool)

Filters the elements of an observable sequence of Harp messages based on their message type.

public static IObservable<HarpMessage> Where(this IObservable<HarpMessage> source, MessageType messageType, bool allowErrors)

Parameters

source IObservable<HarpMessage>

The observable sequence whose messages to filter.

messageType MessageType

The message type to test for a match.

allowErrors bool

true to allow error messages in the filter; otherwise, false.

Returns

IObservable<HarpMessage>

An observable sequence that contains messages from the input sequence that match the specified messageType.

Where(IObservable<HarpMessage>, int)

Filters the elements of an observable sequence of Harp messages based on their address.

public static IObservable<HarpMessage> Where(this IObservable<HarpMessage> source, int address)

Parameters

source IObservable<HarpMessage>

The observable sequence whose messages to filter.

address int

The address to test for a match.

Returns

IObservable<HarpMessage>

An observable sequence that contains messages from the input sequence that match the specified address.

Where(IObservable<HarpMessage>, int, MessageType)

Filters the elements of an observable sequence of Harp messages based on their address and message type.

public static IObservable<HarpMessage> Where(this IObservable<HarpMessage> source, int address, MessageType messageType)

Parameters

source IObservable<HarpMessage>

The observable sequence whose messages to filter.

address int

The address to test for a match.

messageType MessageType

The message type to test for a match.

Returns

IObservable<HarpMessage>

An observable sequence that contains messages from the input sequence that match the specified address and messageType.

Where(IObservable<HarpMessage>, int, MessageType, bool)

Filters the elements of an observable sequence of Harp messages based on their address and message type.

public static IObservable<HarpMessage> Where(this IObservable<HarpMessage> source, int address, MessageType messageType, bool allowErrors)

Parameters

source IObservable<HarpMessage>

The observable sequence whose messages to filter.

address int

The address to test for a match.

messageType MessageType

The message type to test for a match.

allowErrors bool

true to allow error messages in the filter; otherwise, false.

Returns

IObservable<HarpMessage>

An observable sequence that contains messages from the input sequence that match the specified address and messageType.

Where(IObservable<HarpMessage>, int, bool)

Filters the elements of an observable sequence of Harp messages based on their address.

public static IObservable<HarpMessage> Where(this IObservable<HarpMessage> source, int address, bool allowErrors)

Parameters

source IObservable<HarpMessage>

The observable sequence whose messages to filter.

address int

The address to test for a match.

allowErrors bool

true to allow error messages in the filter; otherwise, false.

Returns

IObservable<HarpMessage>

An observable sequence that contains messages from the input sequence that match the specified address.