def end_parallel(self):
outport = self.oport<EOL>if isinstance(self.oport.operator, streamsx.topology.graph.Marker):<EOL><INDENT>if self.oport.operator.kind == "<STR_LIT>":<EOL><INDENT>pto = self.topology.graph.addPassThruOperator()<EOL>pto.addInputPort(outputPort=self.oport)<EOL>outport = pto.addOutputPort(schema=self.oport.schema)<EOL><DEDENT><DEDENT>op = self.topology.graph.addOperator("<STR_LIT>")<EOL>op.addInputPort(outputPort=outport)<EOL>oport = op.addOutputPort(schema=self.oport.schema)<EOL>endP = Stream(self.topology, oport)<EOL>return endP<EOL>
Ends a parallel region by merging the channels into a single stream.

Returns:
    Stream: Stream for which subsequent transformations are no longer parallelized.

.. seealso:: :py:meth:`set_parallel`, :py:meth:`parallel`