MemoryStreamProvider 类

定义

这是一个持久流提供程序,它使用内存中粒度对事件进行排队。 这主要是出于测试目的。

public class MemoryStreamProvider : Orleans.Providers.Streams.Common.PersistentStreamProvider<Orleans.Providers.MemoryAdapterFactory<Orleans.Providers.DefaultMemoryMessageBodySerializer>>
type MemoryStreamProvider = class
    inherit PersistentStreamProvider<MemoryAdapterFactory<DefaultMemoryMessageBodySerializer>>
Public Class MemoryStreamProvider
Inherits PersistentStreamProvider(Of MemoryAdapterFactory(Of DefaultMemoryMessageBodySerializer))
继承

构造函数

MemoryStreamProvider()

这是一个持久流提供程序,它使用内存中粒度对事件进行排队。 这主要是出于测试目的。

属性

IsRewindable

这是一个持久流提供程序,它使用内存中粒度对事件进行排队。 这主要是出于测试目的。

(继承自 PersistentStreamProvider<TAdapterFactory>)
Name

这是一个持久流提供程序,它使用内存中粒度对事件进行排队。 这主要是出于测试目的。

(继承自 PersistentStreamProvider<TAdapterFactory>)

方法

Close()

这是一个持久流提供程序,它使用内存中粒度对事件进行排队。 这主要是出于测试目的。

(继承自 PersistentStreamProvider<TAdapterFactory>)
ExecuteCommand(Int32, Object)

这是一个持久流提供程序,它使用内存中粒度对事件进行排队。 这主要是出于测试目的。

(继承自 PersistentStreamProvider<TAdapterFactory>)
GetStream<T>(Guid, String)

这是一个持久流提供程序,它使用内存中粒度对事件进行排队。 这主要是出于测试目的。

(继承自 PersistentStreamProvider<TAdapterFactory>)
GetStreamSubscriptionManager()

这是一个持久流提供程序,它使用内存中粒度对事件进行排队。 这主要是出于测试目的。

(继承自 PersistentStreamProvider<TAdapterFactory>)
Init(String, IProviderRuntime, IProviderConfiguration)

这是一个持久流提供程序,它使用内存中粒度对事件进行排队。 这主要是出于测试目的。

(继承自 PersistentStreamProvider<TAdapterFactory>)
Start()

这是一个持久流提供程序,它使用内存中粒度对事件进行排队。 这主要是出于测试目的。

(继承自 PersistentStreamProvider<TAdapterFactory>)

扩展方法

TryGetStreamSubscrptionManager(IStreamProvider, IStreamSubscriptionManager)

这是一个持久流提供程序,它使用内存中粒度对事件进行排队。 这主要是出于测试目的。

适用于