Function handle_callback

src/runtime/python_runtime/aimrt_py_chn.py:179–187

(ctx_ref: aimrt_python_runtime.ContextRef, msg_buf: bytes)

        py_pb_ts.SetSerializationTypesSupportedList(["pb", "json"])

        def handle_callback(ctx_ref: aimrt_python_runtime.ContextRef, msg_buf: bytes):
            try:
                msg = _DeserializeProtobufMessage(msg_buf, ctx_ref.GetSerializationType(), msg_type)
                if required_param_count == 1:
                    callback(msg)
                else:
                    callback(ctx_ref, msg)
            except Exception as e:
                print(f"AimRT channel handle get exception, {e}", file=sys.stderr)

        subscriber.PbSubscribeWithCtx(py_pb_ts, handle_callback)