Add parallel streaming (SINK+ SOURCE)