PersistentStreamProvider Methods

Persistent stream provider that uses an adapter for persistence

Create(IServiceProvider, string)

static

public static IStreamProvider Create(IServiceProvider services, string name)

Parameters

servicesIServiceProvider
namestring

ExecuteCommand(int, object?)

View source

public Task<object?> ExecuteCommand(int command, object? arg)

A function to execute a control command.

Parameters

commandint: A serial number of the command.
argobject?: An opaque command argument.

Returns

The value returned from the command handler.

GetStream(StreamId)

View source

public IAsyncStream<T> GetStream<T>(StreamId streamId)

Gets the stream with the specified identity.

Parameters

streamIdStreamId: The stream identifier.

Returns

The stream.

GetStreamSubscriptionManager

View source

public IStreamSubscriptionManager? GetStreamSubscriptionManager()

Gets the stream subscription manager.

Returns

The IStreamSubscriptionManager, or null if the stream provider has no configured subscription manager (e.g. an implicit-subscription-only provider).

Participate(ILifecycleObservable)

View source

public void Participate(ILifecycleObservable lifecycle)

Adds the provided observer as a participant in the lifecycle.

Parameters

lifecycleILifecycleObservable: The observer.

ParticipateIn(IServiceProvider, string)

static

View source

public static ILifecycleParticipant<TLifecycle> ParticipateIn<TLifecycle>(IServiceProvider serviceProvider, string name)

Parameters

serviceProviderIServiceProvider
namestring