Class SourceExtension
Inheritance
SourceExtension
Assembly: Akka.Streams.Azure.StorageQueue.dll
Syntax
public static class SourceExtension
Methods
|
Improve this Doc
View Source
ToStorageQueue<TMat>(Source<String, TMat>, QueueClient, IMaterializer, AddRequestOptions)
Shurtcut for running this Akka.Streams.Dsl.Source<TOut, TMat> with a QueueSink.
The returned Task will be completed with Success when reaching the
normal end of the stream, or completed with Failure if there is a failure signaled in the stream.
Declaration
public static Task ToStorageQueue<TMat>(this Source<string, TMat> source, QueueClient queue, IMaterializer materializer, AddRequestOptions options = null)
Parameters
| Type |
Name |
Description |
| Akka.Streams.Dsl.Source<String, TMat> |
source |
|
| Azure.Storage.Queues.QueueClient |
queue |
|
| Akka.Streams.IMaterializer |
materializer |
|
| AddRequestOptions |
options |
|
Returns
Type Parameters