# EventHubPartitionGeneratorReceiver Methods

[Type overview](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.testing.eventhubpartitiongeneratorreceiver/)

## CloseAsync {#closeasync-ff64574f}

[Dedicated page](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.testing.eventhubpartitiongeneratorreceiver/methods/closeasync-ff64574f/)

[Source](https://github.com/dotnet/orleans/blob/e4e752cedecc2976811db49802c7a999b1f1c704/src/Azure/Orleans.Streaming.EventHubs/Providers/EventDataGeneratorStreamProvider/EventHubPartitionGeneratorReceiver.cs#L54)

```csharp
public Task CloseAsync()
```

Send a clean up message

## ConfigureDataGeneratorForStream(StreamId) {#configuredatageneratorforstream-orleans-runtime-streamid-5146184a}

[Dedicated page](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.testing.eventhubpartitiongeneratorreceiver/methods/configuredatageneratorforstream-orleans-runtime-streamid-5146184a/)

[Source](https://github.com/dotnet/orleans/blob/e4e752cedecc2976811db49802c7a999b1f1c704/src/Azure/Orleans.Streaming.EventHubs/Providers/EventDataGeneratorStreamProvider/EventHubPartitionGeneratorReceiver.cs#L48-L49)

```csharp
public void ConfigureDataGeneratorForStream(StreamId streamId)
```

### Parameters

- `streamId` (`StreamId`)

## ReceiveAsync(int, TimeSpan) {#receiveasync-int-system-timespan-49530062}

[Dedicated page](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.testing.eventhubpartitiongeneratorreceiver/methods/receiveasync-int-system-timespan-49530062/)

[Source](https://github.com/dotnet/orleans/blob/e4e752cedecc2976811db49802c7a999b1f1c704/src/Azure/Orleans.Streaming.EventHubs/Providers/EventDataGeneratorStreamProvider/EventHubPartitionGeneratorReceiver.cs#L29-L37)

```csharp
public Task<IEnumerable<EventData>> ReceiveAsync(int maxCount, TimeSpan waitTime)
```

Send an async message to the partition asking for more messages

### Parameters

- `maxCount` (`int`): Max amount of message which should be delivered in this request
- `waitTime` (`TimeSpan`): Wait time of this request

## StopProducingOnStream(StreamId) {#stopproducingonstream-orleans-runtime-streamid-7c615b0c}

[Dedicated page](/orleans/docs/api/csharp/microsoft.orleans.streaming.eventhubs/orleans.streaming.eventhubs.testing.eventhubpartitiongeneratorreceiver/methods/stopproducingonstream-orleans-runtime-streamid-7c615b0c/)

[Source](https://github.com/dotnet/orleans/blob/e4e752cedecc2976811db49802c7a999b1f1c704/src/Azure/Orleans.Streaming.EventHubs/Providers/EventDataGeneratorStreamProvider/EventHubPartitionGeneratorReceiver.cs#L42-L43)

```csharp
public void StopProducingOnStream(StreamId streamId)
```

### Parameters

- `streamId` (`StreamId`)