Open Grauenwolf opened 5 years ago
...ToDataflow<T>( ITargetBlock<TInput> targetBlock )
Uses the same basic idea as .ToCollection<T>, but with a TPL Dataflow block as the target instead of a collection.
.ToCollection<T>
https://docs.microsoft.com/en-us/dotnet/api/system.threading.tasks.dataflow.dataflowblock.post?view=netcore-2.2
Need an option do deal with rejected messages (Post returns false). By default we should just throw an exception.
Post
...ToDataflow<T>( ITargetBlock<TInput> targetBlock )
Uses the same basic idea as
.ToCollection<T>
, but with a TPL Dataflow block as the target instead of a collection.https://docs.microsoft.com/en-us/dotnet/api/system.threading.tasks.dataflow.dataflowblock.post?view=netcore-2.2