EvolvingStateEnumerable<TPayload> Class

Definition

Namespace:

Microsoft.StreamProcessing

Assembly:

Microsoft.StreamProcessing.dll

An enumerable object whose contents are subject to changes as additional data becomes available from a stream.

public sealed class EvolvingStateEnumerable<TPayload> : IDisposable, IObserver<System.Collections.Generic.IEnumerable<Microsoft.StreamProcessing.ChangeListEvent<TPayload>>>, System.Collections.Generic.IEnumerable<TPayload>

type EvolvingStateEnumerable<'Payload> = class
    interface seq<'Payload>
    interface IEnumerable
    interface IObserver<seq<ChangeListEvent<'Payload>>>
    interface IDisposable

Public NotInheritable Class EvolvingStateEnumerable(Of TPayload)
Implements IDisposable, IEnumerable(Of TPayload), IObserver(Of IEnumerable(Of ChangeListEvent(Of TPayload)))

Type Parameters

TPayload

The type of the streamable payload

Inheritance

Object

EvolvingStateEnumerable<TPayload>

Implements

IEnumerable<TPayload> IDisposable IObserver<IEnumerable<Microsoft.StreamProcessing.ChangeListEvent<TPayload>>>

Constructors

EvolvingStateEnumerable<TPayload>(IStreamable<Empty,TPayload>, QueryContainer, String)

Constructor for this enumerable class, associating this enumerable with a data source from which the enumerable's contents are to be populated or retracted.

Properties

Completed

A flag stating whether the input to this enumerable has ceased producing updates and thus the enumerable is in its final state.

Methods

Dispose()

Dispose the enumerable object by disposing its underlying state.

Explicit Interface Implementations

IEnumerable.GetEnumerator()

IEnumerable<TPayload>.GetEnumerator()

IObserver<IEnumerable<ChangeListEvent<TPayload>>>.OnCompleted()

IObserver<IEnumerable<ChangeListEvent<TPayload>>>.OnError(Exception)

IObserver<IEnumerable<ChangeListEvent<TPayload>>>.OnNext(IEnumerable<ChangeListEvent<TPayload>>)