def test_decorate_with_options(self):
        from furious.async import defaults

        options = {'test': 'me'}

        @defaults(**options)
        def decorated_function():
            pass

        self.assertEqual(options, decorated_function._async_options)
Cancels all consumers, signalling the `start_consuming` loop to
dataset/ETHPy150Open Workiva/furious/furious/tests/test_async.py/TestDefaultsDecorator.test_decorate_with_options--crossover with--dataset/ETHPy150Open pika/pika/pika/adapters/blocking_connection.py/BlockingChannel.stop_consuming