comparison tests/test-batching.py @ 47873:c424ff4807e6

wireprotov1peer: update all rpcs to use the new batchable scheme

If desired, we could keep the future class and the function that
upgrades an old style rpc instead of a new style, for extensions.

Differential Revision: https://phab.mercurial-scm.org/D11212

47872:cdad6560e832

            (
                b'two',
                mangle(two),
            ),
        ]
        encoded_res_future = wireprotov1peer.future()
        yield encoded_args, encoded_res_future
        yield unmangle(encoded_res_future.value)

    @wireprotov1peer.batchable
    def bar(self, b, a):
        encresref = wireprotov1peer.future()
        yield [
            (
                b'b',
                mangle(b),
            ),
            (
                b'a',
                mangle(a),
            ),
        ], encresref
        yield unmangle(encresref.value)

    # greet is coded directly. It therefore does not support batching. If it
    # does appear in a batch, the batch is split around greet, and the call to
    # greet is done in its own roundtrip.
    def greet(self, name=None):

47873:c424ff4807e6

            (
                b'two',
                mangle(two),
            ),
        ]
        return encoded_args, unmangle

    @wireprotov1peer.batchable
    def bar(self, b, a):
        return [
            (
                b'b',
                mangle(b),
            ),
            (
                b'a',
                mangle(a),
            ),
        ], unmangle

    # greet is coded directly. It therefore does not support batching. If it
    # does appear in a batch, the batch is split around greet, and the call to
    # greet is done in its own roundtrip.
    def greet(self, name=None):