fix(imc): report streaming handlers in GetRpcInfo

GetRpcInfo now checks streaming_rpc_handlers when the regular handler
map has no entry, so has_handler correctly returns BML_TRUE for
streaming RPC registrations.

Author: doyaGu

src/Core/ImcBusRpc.cpp

@@ -415,7 +415,12 @@ namespace BML::Core {
             out_info->total_latency_ns =
                 it->second.stats->total_latency_ns.load(std::memory_order_relaxed);
         } else {
-            out_info->has_handler = BML_FALSE;
+            auto streaming_it = m_RpcState.streaming_rpc_handlers.find(rpc_id);
+            out_info->has_handler =
+                (streaming_it != m_RpcState.streaming_rpc_handlers.end() &&
+                 streaming_it->second.handler)
+                ? BML_TRUE
+                : BML_FALSE;
         }
         return BML_RESULT_OK;
     }

tests/ImcBusTest.cpp

@@ -245,6 +245,14 @@ BML_Result CaptureCurrentModuleRpc(BML_Context,
     return BML_RESULT_OK;
 }
 
+BML_Result NoopStreamingRpc(BML_Context,
+                            BML_RpcId,
+                            const BML_ImcMessage *,
+                            BML_RpcStream,
+                            void *) {
+    return BML_RESULT_OK;
+}
+
 void CaptureCurrentModuleFutureCallback(BML_Context,
                                         BML_Future,
                                         void *user_data) {
@@ -1374,6 +1382,22 @@ TEST_F(ImcBusTest, FutureAwaitRejectsMainThreadButWorkerThreadCanWait) {
     EXPECT_EQ(BML_RESULT_OK, UnregisterRpc(rpc));
 }
 
+TEST_F(ImcBusTest, GetRpcInfoReportsRegisteredStreamingHandler) {
+    BML_RpcId rpc = BML_RPC_ID_INVALID;
+    ASSERT_EQ(BML_RESULT_OK, GetRpcId("streaming.rpc.info", &rpc));
+
+    ASSERT_EQ(BML_RESULT_OK,
+              ImcRegisterStreamingRpc(host_mod_, rpc, NoopStreamingRpc, nullptr));
+
+    BML_RpcInfo info = BML_RPC_INFO_INIT;
+    ASSERT_EQ(BML_RESULT_OK, GetRpcInfo(rpc, &info));
+    EXPECT_EQ(info.rpc_id, rpc);
+    EXPECT_EQ(info.has_handler, BML_TRUE);
+    EXPECT_STREQ(info.name, "streaming.rpc.info");
+
+    EXPECT_EQ(BML_RESULT_OK, ImcUnregisterRpc(host_mod_, rpc));
+}
+
 // ========================================================================
 // Priority Message Ordering Tests
 // ========================================================================