Redigera

Dela via


MemoryStreamProvider<TSerializer> Class

Definition

This is a persistent stream provider that uses in-memory grain to queue the events. This is primarily for test purposes.

public class MemoryStreamProvider<TSerializer> : Orleans.Providers.Streams.Common.PersistentStreamProvider<Orleans.Providers.MemoryAdapterFactory<TSerializer>> where TSerializer : class, IMemoryMessageBodySerializer
type MemoryStreamProvider<'Serializer (requires 'Serializer : null and 'Serializer :> IMemoryMessageBodySerializer)> = class
    inherit PersistentStreamProvider<MemoryAdapterFactory<'Serializer>>
Public Class MemoryStreamProvider(Of TSerializer)
Inherits PersistentStreamProvider(Of MemoryAdapterFactory(Of TSerializer))

Type Parameters

TSerializer
Inheritance
MemoryStreamProvider<TSerializer>

Constructors

MemoryStreamProvider<TSerializer>()

Properties

IsRewindable (Inherited from PersistentStreamProvider<TAdapterFactory>)
Name (Inherited from PersistentStreamProvider<TAdapterFactory>)

Methods

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

Extension Methods

TryGetStreamSubscrptionManager(IStreamProvider, IStreamSubscriptionManager)

Applies to