+ async def _init_connection(self):
+ """Init connection if needed"""
+ if not self.connection.version:
+ # TODO: move hello here instead of connection?
+ # Need to consume hello
+ pass
+ if self.password and not self.connection.auth:
+ # Need to send password
+ await self._write_command('password', [self.password])
+ await self._fetch_nothing()
+ self.connection.auth = True
+