MemoryAdapterFactory<TSerializer>.QueueMessageBatchAsync Method
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
Overloads
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>) |
Writes a set of events to the queue as a single batch associated with the provided streamId. |
QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>) |
Writes a set of events to the queue as a single batch associated with the provided streamId. |
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)
Writes a set of events to the queue as a single batch associated with the provided streamId.
public System.Threading.Tasks.Task QueueMessageBatchAsync<T> (Orleans.Runtime.StreamId streamId, System.Collections.Generic.IEnumerable<T> events, Orleans.Streams.StreamSequenceToken token, System.Collections.Generic.Dictionary<string,object> requestContext);
abstract member QueueMessageBatchAsync : Orleans.Runtime.StreamId * seq<'T> * Orleans.Streams.StreamSequenceToken * System.Collections.Generic.Dictionary<string, obj> -> System.Threading.Tasks.Task
override this.QueueMessageBatchAsync : Orleans.Runtime.StreamId * seq<'T> * Orleans.Streams.StreamSequenceToken * System.Collections.Generic.Dictionary<string, obj> -> System.Threading.Tasks.Task
Public Function QueueMessageBatchAsync(Of T) (streamId As StreamId, events As IEnumerable(Of T), token As StreamSequenceToken, requestContext As Dictionary(Of String, Object)) As Task
Type Parameters
- T
The queue element type.
Parameters
- streamId
- StreamId
The stream identifier.
- events
- IEnumerable<T>
The events.
- token
- StreamSequenceToken
The token.
- requestContext
- Dictionary<String,Object>
The request context.
Returns
Task.
Implements
Applies to
QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)
- Source:
- MemoryAdapterFactory.cs
Writes a set of events to the queue as a single batch associated with the provided streamId.
public System.Threading.Tasks.Task QueueMessageBatchAsync<T> (Guid streamGuid, string streamNamespace, System.Collections.Generic.IEnumerable<T> events, Orleans.Streams.StreamSequenceToken token, System.Collections.Generic.Dictionary<string,object> requestContext);
abstract member QueueMessageBatchAsync : Guid * string * seq<'T> * Orleans.Streams.StreamSequenceToken * System.Collections.Generic.Dictionary<string, obj> -> System.Threading.Tasks.Task
override this.QueueMessageBatchAsync : Guid * string * seq<'T> * Orleans.Streams.StreamSequenceToken * System.Collections.Generic.Dictionary<string, obj> -> System.Threading.Tasks.Task
Public Function QueueMessageBatchAsync(Of T) (streamGuid As Guid, streamNamespace As String, events As IEnumerable(Of T), token As StreamSequenceToken, requestContext As Dictionary(Of String, Object)) As Task
Type Parameters
- T
Parameters
- streamGuid
- Guid
- streamNamespace
- String
- events
- IEnumerable<T>
- token
- StreamSequenceToken
- requestContext
- Dictionary<String,Object>