We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
For now it's impossible to specify a consumer filter when registering to an exchange channel:
async def new_consumer(self, callback: object = None, consumer_filters: dict = None, consumer_instance: object = None, size=0, symbol=CHANNEL_WILDCARD, cryptocurrency=CHANNEL_WILDCARD): consumer = consumer_instance if consumer_instance else self.CONSUMER_CLASS(callback, size=size) await self._add_new_consumer_and_run(consumer, cryptocurrency=cryptocurrency, symbol=symbol, with_time_frame=self.WITH_TIME_FRAME) await self._check_producers_state() return consumer
consumer_filters is not taken into acount
The text was updated successfully, but these errors were encountered:
Herklos
No branches or pull requests
For now it's impossible to specify a consumer filter when registering to an exchange channel:
consumer_filters is not taken into acount
The text was updated successfully, but these errors were encountered: