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
StopProducingOnStream(StreamId)
public void StopProducingOnStream(StreamId streamId)Parameters
streamIdStreamId