Class Operators.StreamEnumerable<T>
Enumerable stream class.
Implements
IEnumerable<T>
IDisposable
Namespace: Microsoft.Psi
Assembly: Microsoft.Psi.dll
Syntax
public class StreamEnumerable<T> : IEnumerable
Type Parameters
Name | Description |
---|---|
T | Type of stream messages. |
Constructors
View SourceStreamEnumerable(IProducer<T>, Func<T, Boolean>, DeliveryPolicy<T>, String)
Initializes a new instance of the Operators.StreamEnumerable<T> class.
Declaration
public StreamEnumerable(IProducer<T> source, Func<T, bool> predicate = null, DeliveryPolicy<T> deliveryPolicy = null, string name = "StreamEnumerable")
Parameters
Type | Name | Description |
---|---|---|
IProducer<T> | source | The source stream to enumerate. |
Func<T, System.Boolean> | predicate | Predicate (filter) function. |
DeliveryPolicy<T> | deliveryPolicy | An optional delivery policy. |
String | name | An optional name for this operator. |
Methods
View SourceDispose()
Declaration
public void Dispose()
GetEnumerator()
Declaration
public IEnumerator GetEnumerator()
Returns
Type | Description |
---|---|
IEnumerator |
Implements
IEnumerable<>
IDisposable