Class ProjectionWatcher<TModel>

Namespace

Cratis.Chronicle.Projections

Assembly

Cratis.Chronicle.dll

Represents an implementation of IProjectionWatcher<TModel>.

public class ProjectionWatcher<TModel> : IProjectionWatcher<TModel>, IProjectionWatcher, IDisposable

Type Parameters

TModel

Type of model the watcher is for.

Inheritance

object

ProjectionWatcher<TModel>

Implements

IProjectionWatcher<TModel>

IProjectionWatcher

IDisposable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

ProjectionWatcher(IEventStore, Action)

Initializes a new instance of the ProjectionWatcher<TModel> class.

public ProjectionWatcher(IEventStore eventStore, Action stopped)

Parameters

eventStore IEventStore

IEventStore the watcher is for.

stopped Action

Callback for when the watcher is stopped.

Properties

Observable

Gets the observable for the projection.

public IObservable<ProjectionChangeset<TModel>> Observable { get; }

Property Value

IObservable<ProjectionChangeset<TModel>>

Methods

Dispose()

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

public void Dispose()

Start()

Start the watcher.

public void Start()

Stop()

Stop the watcher. Will be removed from the manager.

public void Stop()