Class Replay
Represents an expression builder that handles sharing of an observable sequence across the encapsulated workflow by eagerly replaying notifications.
Replay
surfaces the observable sequence to the nested workflow using a ReplaySubject
.
ReplaySubject
passes to each subscribed observer all the values from the source sequence, regardless of when the observer subscribes.
Any observers which subscribe late will immediately receive all values which were sent out between the time that ReplaySubject
was created and the time that the observer subscribed to it. It is also possible to parameterize the ReplaySubject
to throw away old values after a certain period of time, or after a specified buffer size is exceeded.
public class Replay : MulticastBuilder, IWorkflowExpressionBuilder, INamedElement, IPropertyMappingBuilder, IExpressionBuilder
- Inheritance
-
Replay
- Implements
- Inherited Members
- Extension Methods
Constructors
Replay()
Initializes a new instance of the Replay class.
public Replay()
Replay(ExpressionBuilderGraph)
Initializes a new instance of the Replay class with the specified expression builder workflow.
public Replay(ExpressionBuilderGraph workflow)
Parameters
workflow
ExpressionBuilderGraphThe expression builder workflow instance that will be used by this builder to generate the output expression tree.
Properties
BufferSize
Gets or sets the maximum element count of the replay buffer.
[Externalizable(false)]
public int? BufferSize { get; set; }
Property Value
- int?
Window
Gets or sets the maximum time length of the replay buffer.
[Externalizable(false)]
public TimeSpan? Window { get; set; }