Function batch_def

flow-python/megflow/func_op.py:105–113

(self, func)

@_common_def(inputs=["inp"], outputs=["out"])
def batch_def(self, func):
    (envelopes, is_closed) = self.inp.batch_recv(self.context.batch_size, self.context.timeout)
    if len(envelopes) == 0:
        return

    func([envelope.msg for envelope in envelopes])

    for envelope in envelopes:
        self.out.send(envelope)