def _restart_stream(self):
self._input_state = "<STR_LIT>"<EOL>self._output_state = "<STR_LIT>"<EOL>self.features = None<EOL>self.transport.restart()<EOL>if self.initiator:<EOL><INDENT>self._send_stream_start(self.stream_id)<EOL><DEDENT>
Restart the stream as needed after SASL and StartTLS negotiation.