CloseAsync
public Task CloseAsync() Send a clean up message
EventHubPartitionGeneratorReceiver Methods
Eventhub receiver which configured with data generator
ConfigureDataGeneratorForStream(StreamId)
public void ConfigureDataGeneratorForStream(StreamId streamId)Parameters
streamIdStreamId
ReceiveAsync(int, TimeSpan)
public Task<IEnumerable<EventData>> ReceiveAsync(int maxCount, TimeSpan waitTime) Send an async message to the partition asking for more messages
Parameters
maxCountint- Max amount of message which should be delivered in this request
waitTimeTimeSpan- Wait time of this request
ReceiveAsync(int, TimeSpan, CancellationToken)
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.
StopProducingOnStream(StreamId)
public void StopProducingOnStream(StreamId streamId)Parameters
streamIdStreamId