Skip to content
Orleans logoMicrosoft Orleans

ClientBuilderStreamingExtensions Methods

Extension methods for configuring streaming on an Orleans client.

AddMemoryStreams(IClientBuilder, string, Action<IClusterClientMemoryStreamConfigurator>)

staticextension
View source
public static IClientBuilder AddMemoryStreams(this IClientBuilder builder, string name, Action<IClusterClientMemoryStreamConfigurator>? configure = null)
Adds a new in-memory stream provider to the client, using the default message serializer (DefaultMemoryMessageBodySerializer).

Parameters

builderIClientBuilder
The builder.
namestring
The stream provider name.
configureAction<IClusterClientMemoryStreamConfigurator>
The configuration delegate.

Returns

The client builder.

AddMemoryStreams(IClientBuilder, string, Action<IClusterClientMemoryStreamConfigurator>)

staticextension
View source
public static IClientBuilder AddMemoryStreams<TSerializer>(this IClientBuilder builder, string name, Action<IClusterClientMemoryStreamConfigurator>? configure = null)
Adds a new in-memory stream provider to the client.

Parameters

builderIClientBuilder
The builder.
namestring
The stream provider name.
configureAction<IClusterClientMemoryStreamConfigurator>
The configuration delegate.

Returns

The client builder.

AddPersistentStreams(IClientBuilder, string, Func<IServiceProvider, string, IQueueAdapterFactory>, Action<IClusterClientPersistentStreamConfigurator>)

staticextension
View source
public static IClientBuilder AddPersistentStreams(this IClientBuilder builder, string name, Func<IServiceProvider, string, IQueueAdapterFactory> adapterFactory, Action<IClusterClientPersistentStreamConfigurator>? configureStream)
Adds a new persistent streams provider to the client.

Parameters

builderIClientBuilder
The builder.
namestring
The stream provider name.
adapterFactoryFunc<IServiceProvider, string, IQueueAdapterFactory>
The adapter factory.
configureStreamAction<IClusterClientPersistentStreamConfigurator>
The configuration delegate.

Returns

The client builder.

AddStreaming(IClientBuilder)

staticextension
View source
public static IClientBuilder AddStreaming(this IClientBuilder builder)
Adds support for streaming to this client.

Parameters

builderIClientBuilder
The builder.

Returns

The client builder.