Edit

Share via


PersistentStreamProvider<TAdapterFactory> Class

Definition

Persistent stream provider that uses an adapter for persistence

public class PersistentStreamProvider<TAdapterFactory> : Orleans.Providers.IControllable, Orleans.Streams.Core.IStreamSubscriptionManagerRetriever where TAdapterFactory : IQueueAdapterFactory, new()
type PersistentStreamProvider<'AdapterFactory (requires 'AdapterFactory :> IQueueAdapterFactory and 'AdapterFactory : (new : unit -> 'AdapterFactory))> = class
    interface IStreamProviderImpl
    interface IStreamProvider
    interface IProvider
    interface IControllable
    interface IStreamSubscriptionManagerRetriever
Public Class PersistentStreamProvider(Of TAdapterFactory)
Implements IControllable, IStreamSubscriptionManagerRetriever

Type Parameters

TAdapterFactory
Inheritance
PersistentStreamProvider<TAdapterFactory>
Derived
Implements

Constructors

PersistentStreamProvider<TAdapterFactory>()

Properties

IsRewindable
Name

Methods

Close()
ExecuteCommand(Int32, Object)
GetStream<T>(Guid, String)
GetStreamSubscriptionManager()
Init(String, IProviderRuntime, IProviderConfiguration)
Start()

Extension Methods

TryGetStreamSubscrptionManager(IStreamProvider, IStreamSubscriptionManager)

Applies to