# AsyncBatchObservableExtensions

Package: [Microsoft.Orleans.Streaming](/orleans/docs/api/csharp/microsoft.orleans.streaming/) 10.0.0

[NuGet package](https://www.nuget.org/packages/Microsoft.Orleans.Streaming) | [Source](https://github.com/dotnet/orleans/blob/e4e752cedecc2976811db49802c7a999b1f1c704/src/Orleans.Streaming/Extensions/AsyncBatchObservableExtensions.cs#L10)

```csharp
public static class AsyncBatchObservableExtensions
```

Extension methods for `Orleans.Streams.IAsyncBatchObservable-1`.

## Methods

- [SubscribeAsync(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>, Task>)](/orleans/docs/api/csharp/microsoft.orleans.streaming/orleans.streams.asyncbatchobservableextensions/methods/subscribeasync-1-this-orleans-streams-iasyncbatchobservable-t-system-func-system-01b55956/)
- [SubscribeAsync(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>, Task>, Func<Exception, Task>)](/orleans/docs/api/csharp/microsoft.orleans.streaming/orleans.streams.asyncbatchobservableextensions/methods/subscribeasync-1-this-orleans-streams-iasyncbatchobservable-t-system-func-system-57e4421f/)
- [SubscribeAsync(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>, Task>, Func<Exception, Task>, Func<Task>)](/orleans/docs/api/csharp/microsoft.orleans.streaming/orleans.streams.asyncbatchobservableextensions/methods/subscribeasync-1-this-orleans-streams-iasyncbatchobservable-t-system-func-system-5927d51e/)
- [SubscribeAsync(IAsyncBatchObservable<T>, Func<IList<SequentialItem<T>>, Task>, Func<Task>)](/orleans/docs/api/csharp/microsoft.orleans.streaming/orleans.streams.asyncbatchobservableextensions/methods/subscribeasync-1-this-orleans-streams-iasyncbatchobservable-t-system-func-system-f4d1e53d/)