Function sink_def

flow-python/megflow/func_op.py:86–92

(self, func)

@_common_def(inputs=["inp"])
def sink_def(self, func):
    envelope = self.inp.recv()

    if envelope is None:
        return

    func(envelope.msg)


@_common_def(outputs=["out"])