def complete(self, stream):
assert not self.is_complete()<EOL>self._marker.addInputPort(outputPort=stream.oport)<EOL>self.stream.oport.schema = stream.oport.schema<EOL>self._pending_schema._set(self.stream.oport.schema)<EOL>stream.oport.operator._start_op = True<EOL>
Complete the pending stream.

        Any connections made to :py:attr:`stream` are connected to `stream` once
        this method returns.

        Args:
            stream(Stream): Stream that completes the connection.