Class Operators.StreamObservable<T>
Observable stream class.
Namespace: Microsoft.Psi
Assembly: Microsoft.Psi.dll
Syntax
public class StreamObservable<T> : IObservable<T>
Type Parameters
Name | Description |
---|---|
T | Type of stream messages. |
Constructors
View SourceStreamObservable(IProducer<T>, DeliveryPolicy<T>, String)
Initializes a new instance of the Operators.StreamObservable<T> class.
Declaration
public StreamObservable(IProducer<T> stream, DeliveryPolicy<T> deliveryPolicy = null, string name = "StreamObservable")
Parameters
Type | Name | Description |
---|---|---|
IProducer<T> | stream | The source stream to observe. |
DeliveryPolicy<T> | deliveryPolicy | An optional delivery policy. |
String | name | An optional name for this stream operator. |
Properties
View SourceHasSubscribers
Gets a value indicating whether this observable stream has subscribers.
Declaration
public bool HasSubscribers { get; }
Property Value
Type | Description |
---|---|
System.Boolean |
Methods
View SourceSubscribe(IObserver<T>)
Declaration
public IDisposable Subscribe(IObserver<T> observer)
Parameters
Type | Name | Description |
---|---|---|
IObserver<T> | observer |
Returns
Type | Description |
---|---|
IDisposable |