handle edge parallelism a bit better with input streams