Class AsyncStreamExtensions
Extension methods that simplify work with gRPC streaming calls.
Inheritance
System.Object
AsyncStreamExtensions
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: Grpc.Core.Utils
Assembly: Grpc.Core.dll
Syntax
public static class AsyncStreamExtensionsMethods
ForEachAsync<T>(IAsyncStreamReader<T>, Func<T, Task>)
Reads the entire stream and executes an async action for each element.
Declaration
public static Task ForEachAsync<T>(this IAsyncStreamReader<T> streamReader, Func<T, Task> asyncAction)
where T : classParameters
| Type | Name | Description |
|---|---|---|
| IAsyncStreamReader<T> | streamReader | |
| System.Func<T, System.Threading.Tasks.Task> | asyncAction |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task |
Type Parameters
| Name | Description |
|---|---|
| T |
ToListAsync<T>(IAsyncStreamReader<T>)
Reads the entire stream and creates a list containing all the elements read.
Declaration
public static Task<List<T>> ToListAsync<T>(this IAsyncStreamReader<T> streamReader)
where T : classParameters
| Type | Name | Description |
|---|---|---|
| IAsyncStreamReader<T> | streamReader |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task<System.Collections.Generic.List<T>> |
Type Parameters
| Name | Description |
|---|---|
| T |
WriteAllAsync<T>(IClientStreamWriter<T>, IEnumerable<T>, Boolean)
Writes all elements from given enumerable to the stream. Completes the stream afterwards unless close = false.
Declaration
public static Task WriteAllAsync<T>(this IClientStreamWriter<T> streamWriter, IEnumerable<T> elements, bool complete = true)
where T : classParameters
| Type | Name | Description |
|---|---|---|
| IClientStreamWriter<T> | streamWriter | |
| System.Collections.Generic.IEnumerable<T> | elements | |
| System.Boolean | complete |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task |
Type Parameters
| Name | Description |
|---|---|
| T |
WriteAllAsync<T>(IServerStreamWriter<T>, IEnumerable<T>)
Writes all elements from given enumerable to the stream.
Declaration
public static Task WriteAllAsync<T>(this IServerStreamWriter<T> streamWriter, IEnumerable<T> elements)
where T : classParameters
| Type | Name | Description |
|---|---|---|
| IServerStreamWriter<T> | streamWriter | |
| System.Collections.Generic.IEnumerable<T> | elements |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task |
Type Parameters
| Name | Description |
|---|---|
| T |