Create(IServiceProvider, string)
static
public static IStreamProvider Create(IServiceProvider services, string name)Parameters
servicesIServiceProvidernamestring
PersistentStreamProvider Methods
Persistent stream provider that uses an adapter for persistence
ExecuteCommand(int, object)
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)
public IAsyncStream<T> GetStream<T>(StreamId streamId) Gets the stream with the specified identity.
Parameters
streamIdStreamId- The stream identifier.
Returns
The stream.
GetStreamSubscriptionManager
public IStreamSubscriptionManager GetStreamSubscriptionManager() Gets the stream subscription manager.
Returns
Participate(ILifecycleObservable)
public void Participate(ILifecycleObservable lifecycle) Adds the provided observer as a participant in the lifecycle.
Parameters
lifecycleILifecycleObservable- The observer.
ParticipateIn(IServiceProvider, string)
static
public static ILifecycleParticipant<TLifecycle> ParticipateIn<TLifecycle>(IServiceProvider serviceProvider, string name)Parameters
serviceProviderIServiceProvidernamestring