Function source_def

flow-python/megflow/func_op.py:96–101

(self, func)

@_common_def(outputs=["out"])
def source_def(self, func):
    from megflow import Envelope
    i = 0
    for msg in func():
        self.out.send(Envelope.pack(msg, info={'partial_id':i}))
        i += 1


@_common_def(inputs=["inp"], outputs=["out"])