EventHubPartitionGeneratorReceiver.ReceiveAsync(int, TimeSpan, CancellationToken)

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.EventHubs
4. EventHubPartitionGeneratorReceiver
5. Methods
6. ReceiveAsync(int, TimeSpan, CancellationToken)

Markdown

ReceiveAsync(int, TimeSpan, CancellationToken)

View source

public Task<IEnumerable<EventData>> ReceiveAsync(int maxCount, TimeSpan waitTime, CancellationToken cancellationToken)

Sends an asynchronous request for more messages from the partition.

Parameters

maxCountint

The maximum number of messages to return.

waitTimeTimeSpan

The maximum wait time.

cancellationTokenCancellationToken

The token used to cancel the operation.

Returns

The received messages.