(self, url, messageHashes, payload, channel, params={})
| 1992 | return await self.watch(url, messageHash, message, messageHash, subscription) |
| 1993 | |
| 1994 | async def subscribe_public_multiple(self, url, messageHashes, payload, channel, params={}): |
| 1995 | requestId = self.request_id() |
| 1996 | time = self.seconds() |
| 1997 | request = { |
| 1998 | 'id': requestId, |
| 1999 | 'time': time, |
| 2000 | 'channel': channel, |
| 2001 | 'event': 'subscribe', |
| 2002 | 'payload': payload, |
| 2003 | } |
| 2004 | message = self.extend(request, params) |
| 2005 | return await self.watch_multiple(url, messageHashes, message, messageHashes) |
| 2006 | |
| 2007 | async def un_subscribe_public_multiple(self, url, topic, symbols, messageHashes, subMessageHashes, payload, channel, params={}): |
| 2008 | requestId = self.request_id() |
no test coverage detected