Class ReadModelWatcher<TReadModel>

Represents an implementation of IReadModelWatcher<TReadModel>.

public class ReadModelWatcher<TReadModel> : IReadModelWatcher<TReadModel>, IReadModelWatcher, IDisposable

Inherited Members: object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

Initializes a new instance of the ReadModelWatcher<TReadModel> class.

public ReadModelWatcher(IEventStore eventStore, Action stopped, JsonSerializerOptions jsonSerializerOptions)

eventStore IEventStore: IEventStore the watcher is for.
stopped Action: Callback for when the watcher is stopped.
jsonSerializerOptions JsonSerializerOptions: Options for JSON serialization.

Gets the observable for the read model.

public IObservable<ReadModelChangeset<TReadModel>> Observable { get; }

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()

Start the watcher.

public void Start()

Stop the watcher. Will be removed from the manager.

public void Stop()