Class ReadModelObservation<TReadModel>

Namespace

Cratis.Chronicle.ReadModels

Assembly

Cratis.Chronicle.dll

Replays the latest collection while owning the lifetime of a dedicated read model stream.

public sealed class ReadModelObservation<TReadModel> : ISubject<IEnumerable<TReadModel>>, ISubject<IEnumerable<TReadModel>, IEnumerable<TReadModel>>, IObserver<IEnumerable<TReadModel>>, IObservable<IEnumerable<TReadModel>>, IDisposable

Type Parameters

TReadModel

The read model type.

Inheritance

object

ReadModelObservation<TReadModel>

Implements

ISubject<IEnumerable<TReadModel>>

ISubject<IEnumerable<TReadModel>, IEnumerable<TReadModel>>

IObserver<IEnumerable<TReadModel>>

IObservable<IEnumerable<TReadModel>>

IDisposable

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

MethodCalls.CallGenericMethod<TOut, T>(T, Expression<Func<T, Func<TOut>>>, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1>(T, Expression<Func<T, Func<T1, TOut>>>, T1, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2>(T, Expression<Func<T, Func<T1, T2, TOut>>>, T1, T2, params Type[])

MethodCalls.CallGenericMethod<TOut, T, T1, T2, T3>(T, Expression<Func<T, Func<T1, T2, T3, TOut>>>, T1, T2, T3, params Type[])

ConverterExtensions.ConvertTo(object, Type)

ConceptExtensions.GetConceptValue(object)

ConceptExtensions.IsConcept(object)

JsonValueExtensions.ToJsonValue(object?)

ObservableExtensions.InvokeAndWrapWithSubject<TResult>(object, Func<CancellationToken, IObservable<TResult>>)

ObservableExtensions.InvokeAndWrapWithTransformSubject<TResult, TSource>(object, Func<CancellationToken, IObservable<TSource>>, Func<TSource, TResult>)

Constructors

ReadModelObservation(IObservable<IEnumerable<TReadModel>>)

Replays the latest collection while owning the lifetime of a dedicated read model stream.

public ReadModelObservation(IObservable<IEnumerable<TReadModel>> source)

Parameters

source IObservable<IEnumerable<TReadModel>>

The stream to subscribe to when the first subscriber arrives.

Methods

Dispose()

public void Dispose()

OnCompleted()

public void OnCompleted()

OnError(Exception)

public void OnError(Exception error)

Parameters

error Exception

OnNext(IEnumerable<TReadModel>)

public void OnNext(IEnumerable<TReadModel> value)

Parameters

value IEnumerable<TReadModel>

Subscribe(IObserver<IEnumerable<TReadModel>>)

public IDisposable Subscribe(IObserver<IEnumerable<TReadModel>> observer)

Parameters

observer IObserver<IEnumerable<TReadModel>>

Returns

IDisposable