trustmaster/goflow — Issue #1: Wait for current input processing to be finished before closing ports
Author: trustmaster
Created: 2012-02-14 14:14:11+00:00
State: open
Labels: enhancement

Currently components are terminated immediately as soon as their inports are closed. But some input can still be in processing after the output is closed, this leads to "send on a closed channel" errors.

Additional synchronization should be added so that when inputs are closed, the component doesn't accept any input anymore, waits until running input handlers finish and closes outports afterwards.