Create writable streams that process items in parallel.