Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(40)  |  Call(40)  |  Derive(0)  |  Import(0)
Invoked by the Channel object when passed frames that are not
setup in the rpc process and that don't have explicit reply types
defined. This includes Basic.Publish, Basic.GetOk and Basic.Return

:param Method|Header|Body frame_value: The frame to process

src/p/i/pika-HEAD/tests/content_frame_dispatcher_tests.py   pika(Download)
    def test_process_with_basic_deliver(self):
        value = frame.Method(1, spec.Basic.Deliver())
        obj = channel.ContentFrameDispatcher()
        obj.process(value)
        self.assertEqual(obj._method_frame, value)
 
    def test_process_with_content_header(self):
        value = frame.Header(1, 100, spec.BasicProperties)
        obj = channel.ContentFrameDispatcher()
        obj.process(value)
    def test_process_with_body_frame_partial(self):
        obj = channel.ContentFrameDispatcher()
        value = frame.Header(1, 100, spec.BasicProperties)
        obj.process(value)
        value = frame.Method(1, spec.Basic.Deliver())
        obj.process(value)
        value = frame.Body(1, 'abc123')
        obj.process(value)