(self, url, messageType)
| 2026 | return await self.watch_multiple(url, messageHashes, message, messageHashes, sub) |
| 2027 | |
| 2028 | async def authenticate(self, url, messageType): |
| 2029 | channel = messageType + '.login' |
| 2030 | client = self.client(url) |
| 2031 | messageHash = 'authenticated' |
| 2032 | future = client.reusableFuture(messageHash) |
| 2033 | authenticated = self.safe_value(client.subscriptions, messageHash) |
| 2034 | if authenticated is None: |
| 2035 | return await self.request_private(url, {}, channel, messageHash) |
| 2036 | return future |
| 2037 | |
| 2038 | def handle_authentication_message(self, client: Client, message): |
| 2039 | messageHash = 'authenticated' |
no test coverage detected