Add Flow Output Assignment

One should be able to assign existing ports to flow output "channels". Internally this is already possible with stages. With assignable output "channels" flows can be plugged together, even if stag...

Id #4726 | Release: None | Updated: Feb 2, 2013 at 2:12 AM by ralfw | Created: Jul 6, 2009 at 11:18 AM by ralfw

Add Dispatcher Configuration

Currently stages don´t use an explicit Disptacher. Each creates a new DisptacherQueue using the CLR thread pool. To be more flexible/scalable, one should be able to assign a customer Dispatcher (or...

Id #4725 | Release: None | Updated: Feb 2, 2013 at 2:12 AM by ralfw | Created: Jul 6, 2009 at 11:15 AM by ralfw

Add Pipe Operator to Concatenate Flows

Currenty flows can be concatenated by calling Concat<>(). But why not be able to use | for this? It´s the etablished operator for building simple single flows. Shouldn´t be that difficult using ope...

Id #4685 | Release: None | Updated: Feb 2, 2013 at 2:12 AM by ralfw | Created: Jul 4, 2009 at 1:46 PM by ralfw

Add Iterator Stages

Currently stages are "monolithic". They receive input and as long as they work on it they occupy a thread. Only after the stage function finished the CCR gets the chance to run another stage.   For...

Id #4676 | Release: None | Updated: Feb 2, 2013 at 2:12 AM by ralfw | Created: Jul 3, 2009 at 9:30 AM by ralfw

Add Switches

Alternate paths should be possible. A flow should be able to take one or another route from start to finish. A Switch stages would solve this problem, e.g.   ...Do<int>.Switch<int, string>(Alternat...

Id #4668 | Release: None | Updated: Feb 2, 2013 at 2:12 AM by ralfw | Created: Jul 2, 2009 at 4:44 PM by ralfw

Add Timeouts

Sometimes a stage A needs to accomplish its task within a given time. If not output is produced until a timeout the flow should be aborted. Flow stages thus should optionally carry a timeout value,...

Id #4667 | Release: None | Updated: Feb 2, 2013 at 2:12 AM by ralfw | Created: Jul 2, 2009 at 4:39 PM by ralfw

Add Scatter + Gather

Add a stage to not only scatter the processing onto parallel threads, but which also allows to gather the results later on. Think of a flow which receives a directory name and is supposed to produc...

Id #4666 | Release: None | Updated: Feb 2, 2013 at 2:12 AM by ralfw | Created: Jul 2, 2009 at 4:33 PM by ralfw

  • 1-7 of 7 Work Items
    • Previous
    • 1
    • Next
    • Showing
    • All
    • Work Items