Function ros2_callback_wrapper

src/runtime/python_runtime/aimrt_py_chn.py:197–204

(ctx_ref: aimrt_python_runtime.ContextRef, msg)

        py_ros2_ts.SetSerializationTypesSupportedList(["ros2"])

        def ros2_callback_wrapper(ctx_ref: aimrt_python_runtime.ContextRef, msg):
            try:
                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)

        aimrt_py_ros2.Ros2SubscribeWithCtx(subscriber, py_ros2_ts, msg_type, ros2_callback_wrapper)