Class ReadModelChangesetExtensions

Namespace: Cratis.Chronicle.ReadModels

Assembly: Cratis.Chronicle.dll

Extension methods for converting observables of ReadModelChangeset<TReadModel> to subjects.

public static class ReadModelChangesetExtensions

Inheritance: object

ReadModelChangesetExtensions

Inherited Members: object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

ToObservableReadModel<TReadModel>(IObservable<ReadModelChangeset<TReadModel>>)

Convert an observable of ReadModelChangeset<TReadModel> to a subject of TReadModel that emits the read model instances for non-removed changesets. The subject will emit the read model instance for each changeset where Removed is false and ReadModel is not null.

public static ISubject<TReadModel> ToObservableReadModel<TReadModel>(this IObservable<ReadModelChangeset<TReadModel>> source)

Parameters

source IObservable<ReadModelChangeset<TReadModel>>: The source observable of ReadModelChangeset<TReadModel>.

Returns

ISubject<TReadModel>: A subject of TReadModel that emits the read model instances for non-removed changesets.

Type Parameters