CODEWITHSUNDEEP
c#.nettask-parallel-librarytpl-dataflowdataflow
Matt L
Matt L

Reputation: 81

How to construct a TransformManyBlock with a delegate

I'm new to C# TPL and DataFlow and I'm struggling to work out how to implement the TPL DataFlow TransformManyBlock. I'm translating some other code into DataFlow. My (simplified) original code was something like this:

private IEnumerable<byte[]> ExtractFromByteStream(Byte[] byteStream)
{
    yield return byteStream; // Plus operations on the array
}

And in another method I would call it like this:

foreach (byte[] myByteArray in ExtractFromByteStream(byteStream))
{
    // Do stuff with myByteArray
}

I'm trying to create a TransformManyBlock to produce multiple little arrays (actually data packets) that come from the larger input array (actually a binary stream), so both in and out are of type byte[].

I tried what I've put below but I know I've got it wrong. I want to construct this block using the same function as before and to just wrap the TransformManyBlock around it. I got an error "The call is ambiguous..."

var streamTransformManyBlock = new TransformManyBlock<byte[], byte[]>(ExtractFromByteStream);

Upvotes: 6

Views: 1623

Answers (1)

i3arnon
i3arnon

Reputation: 116558

The compiler has troubles with inferring the types. You need to either specify the delegate type explicitly to disambiguate the call:

var block = new TransformManyBlock<byte[], byte[]>(
    (Func<byte[], IEnumerable<byte[]>>) ExtractFromByteStream);

Or you can use a lambda expression that calls into that method:

var block = new TransformManyBlock<byte[], byte[]>(
    bytes => ExtractFromByteStream(bytes));

Upvotes: 7

Related Questions