def end_low_latency(self):
op = self.topology.graph.addOperator("<STR_LIT>")<EOL>op.addInputPort(outputPort=self.oport)<EOL>oport = op.addOutputPort(schema=self.oport.schema)<EOL>return Stream(self.topology, oport)<EOL>
Returns a Stream that is no longer guaranteed to run in the same process
as the calling stream.

Returns:
    Stream