Class AlpacaDataSubscriptionExtensions
Set of extension methods for the IAlpacaDataSubscription<TApi> interface.
Inheritance
System.Object
AlpacaDataSubscriptionExtensions
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
Namespace: Alpaca.Markets.Extensions
Assembly: Alpaca.Markets.Extensions.dll
Syntax
public static class AlpacaDataSubscriptionExtensionsMethods
| Improve this Doc View SourceAsAsyncEnumerable<TItem>(IAlpacaDataSubscription<TItem>)
Converts Received event into asynchronous enumerable (reactive event consuming style) using unbound channel.
Declaration
public static IAsyncEnumerable<TItem> AsAsyncEnumerable<TItem>(this IAlpacaDataSubscription<TItem> subscription)Parameters
| Type | Name | Description |
|---|---|---|
| IAlpacaDataSubscription<TItem> | subscription | Original subscription object for wrapping. |
Returns
| Type | Description |
|---|---|
| IAsyncEnumerable<TItem> | Stream of items received from server in form of async enumerable. |
Type Parameters
| Name | Description |
|---|---|
| TItem | Type of streaming item provided via |
AsAsyncEnumerable<TItem>(IAlpacaDataSubscription<TItem>, CancellationToken)
Converts Received event into asynchronous enumerable (reactive event consuming style) using unbound channel.
Declaration
public static async IAsyncEnumerable<TItem> AsAsyncEnumerable<TItem>(this IAlpacaDataSubscription<TItem> subscription, CancellationToken cancellationToken)Parameters
| Type | Name | Description |
|---|---|---|
| IAlpacaDataSubscription<TItem> | subscription | Original subscription object for wrapping. |
| CancellationToken | cancellationToken | A cancellation token that can be used by other objects or threads to receive notice of cancellation. |
Returns
| Type | Description |
|---|---|
| IAsyncEnumerable<TItem> | Stream of items received from server in form of async enumerable. |
Type Parameters
| Name | Description |
|---|---|
| TItem | Type of streaming item provided via |