def METHOD_NAME(self, ws):
    request = json.dumps({
        'id': self.id,
        'type': 'subscribe',
        'topic': f'/market/{self.stream}:{self.symbol}',
        'privateChannel': False,
        'response': True
    })
    ws.send(request)