feat: add Kotlin coroutine extension layer (Mono -> suspend, Flux -> Flow)

agentscope-dependencies-bom/pom.xml

@@ -232,6 +232,20 @@
                 <version>${qdrant.version}</version>
             </dependency>
 
+            <!-- Kotlin Coroutines -->
+            <dependency>
+                <groupId>org.jetbrains.kotlinx</groupId>
+                <artifactId>kotlinx-coroutines-core</artifactId>
+                <version>${kotlin.coroutines.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>org.jetbrains.kotlinx</groupId>
+                <artifactId>kotlinx-coroutines-reactor</artifactId>
+                <version>${kotlin.coroutines.version}</version>
+            </dependency>
+
+
             <!-- Milvus Java SDK -->
             <dependency>
                 <groupId>io.milvus</groupId>
@@ -310,9 +324,10 @@
                 <version>${a2a-transport-jsonrpc.version}</version>
             </dependency>
 
+
             <!-- Jedis client for Redis-based session implementation -->
             <dependency>
-                <groupId>redis.clients</groupId>
+                <groupId>redis.clients</groupId> 
                 <artifactId>jedis</artifactId>
                 <version>${jedis.version}</version>
             </dependency>

agentscope-extensions/agentscope-kotlin/pom.xml

@@ -0,0 +1,67 @@
+<!--
+  ~ Copyright 2024-2026 the original author or authors.
+  ~
+  ~ Licensed under the Apache License, Version 2.0 (the "License");
+  ~ you may not use this file except in compliance with the License.
+  ~ You may obtain a copy of the License at
+  ~
+  ~     http://www.apache.org/licenses/LICENSE-2.0
+  ~
+  ~ Unless required by applicable law or agreed to in writing, software
+  ~ distributed under the License is distributed on an "AS IS" BASIS,
+  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~ See the License for the specific language governing permissions and
+  ~ limitations under the License.
+-->
+
+
+
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+                             http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>io.agentscope</groupId>
+        <artifactId>agentscope-extensions</artifactId>
+        <version>${revision}</version>
+        <relativePath>../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>agentscope-extensions-kotlin</artifactId>
+    <name>AgentScope Kotlin Coroutine Extensions</name>
+    <packaging>jar</packaging>
+
+    <dependencies>
+        <!-- AgentScope core -->
+        <dependency>
+            <groupId>io.agentscope</groupId>
+            <artifactId>agentscope-core</artifactId>
+        </dependency>
+
+        <!-- Kotlin coroutines -->
+        <dependency>
+            <groupId>org.jetbrains.kotlinx</groupId>
+            <artifactId>kotlinx-coroutines-core</artifactId>
+        </dependency>
+
+        <!-- Reactor <-> Coroutine bridge -->
+        <dependency>
+            <groupId>org.jetbrains.kotlinx</groupId>
+            <artifactId>kotlinx-coroutines-reactor</artifactId>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.jetbrains.kotlin</groupId>
+                <artifactId>kotlin-maven-plugin</artifactId>
+                <version>${kotlin.version}</version>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

agentscope-extensions/agentscope-kotlin/src/main/kotlin/io/agentscope/kotlin/AgentExtensions.kt

@@ -0,0 +1,96 @@
+<!--
+  ~ Copyright 2024-2026 the original author or authors.
+  ~
+  ~ Licensed under the Apache License, Version 2.0 (the "License");
+  ~ you may not use this file except in compliance with the License.
+  ~ You may obtain a copy of the License at
+  ~
+  ~     http://www.apache.org/licenses/LICENSE-2.0
+  ~
+  ~ Unless required by applicable law or agreed to in writing, software
+  ~ distributed under the License is distributed on an "AS IS" BASIS,
+  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  ~ See the License for the specific language governing permissions and
+  ~ limitations under the License.
+-->
+
+
+
+
+
+package io.agentscope.kotlin
+
+import io.agentscope.core.agent.Agent
+import io.agentscope.core.agent.Event
+import io.agentscope.core.agent.StreamOptions
+import io.agentscope.core.message.Msg
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.reactor.awaitFirstOrNull
+import kotlinx.coroutines.reactor.awaitSingle
+import kotlinx.coroutines.reactive.asFlow
+
+/* ---------- call(...) -> suspend ---------- */
+
+suspend fun Agent.callSuspend(msg: Msg): Msg =
+    this.call(msg).awaitSingle()
+
+suspend fun Agent.callSuspend(msgs: List<Msg>): Msg =
+    this.call(msgs).awaitSingle()
+
+suspend fun Agent.callSuspend(): Msg =
+    this.call().awaitSingle()
+
+suspend fun Agent.callSuspend(
+    msg: Msg,
+    structuredModel: Class<*>
+): Msg =
+    this.call(msg, structuredModel).awaitSingle()
+
+suspend fun Agent.callSuspend(
+    msgs: List<Msg>,
+    structuredModel: Class<*>
+): Msg =
+    this.call(msgs, structuredModel).awaitSingle()
+
+suspend fun Agent.callSuspend(
+    structuredModel: Class<*>
+): Msg =
+    this.call(structuredModel).awaitSingle()
+
+/* ---------- observe(...) -> suspend ---------- */
+
+suspend fun Agent.observeSuspend(msg: Msg) {
+    this.observe(msg).awaitFirstOrNull()
+}
+
+suspend fun Agent.observeSuspend(msgs: List<Msg>) {
+    this.observe(msgs).awaitFirstOrNull()
+}
+
+/* ---------- stream(...) -> Flow ---------- */
+
+fun Agent.streamFlow(
+    msg: Msg,
+    options: StreamOptions = StreamOptions.defaults()
+): Flow<Event> =
+    this.stream(msg, options).asFlow()
+
+fun Agent.streamFlow(
+    msgs: List<Msg>,
+    options: StreamOptions = StreamOptions.defaults()
+): Flow<Event> =
+    this.stream(msgs, options).asFlow()
+
+fun Agent.streamFlow(
+    msg: Msg,
+    options: StreamOptions,
+    structuredModel: Class<*>
+): Flow<Event> =
+    this.stream(msg, options, structuredModel).asFlow()
+
+fun Agent.streamFlow(
+    msgs: List<Msg>,
+    options: StreamOptions,
+    structuredModel: Class<*>
+): Flow<Event> =
+    this.stream(msgs, options, structuredModel).asFlow()

agentscope-extensions/pom.xml

@@ -17,19 +17,44 @@
 
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0
+                             http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
     <modelVersion>4.0.0</modelVersion>
+
     <parent>
         <groupId>io.agentscope</groupId>
         <artifactId>agentscope-parent</artifactId>
         <version>${revision}</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
-    <name>AgentScope Java - Extensions</name>
+    <groupId>io.agentscope</groupId>
     <artifactId>agentscope-extensions</artifactId>
+    <name>AgentScope Java - Extensions</name>
     <packaging>pom</packaging>
 
+
+    <properties>
+        <!-- Kotlin -->
+        <kotlin.version>1.9.24</kotlin.version>
+        <kotlin.coroutines.version>1.8.1</kotlin.coroutines.version>
+    </properties>
+
+
+    <dependencyManagement>
+        <dependencies>
+            <dependency>
+                <groupId>io.agentscope</groupId>
+                <artifactId>agentscope-dependencies-bom</artifactId>
+                <version>${revision}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+
+
     <modules>
         <module>agentscope-extensions-a2a</module>
         <module>agentscope-extensions-autocontext-memory</module>
@@ -52,4 +77,5 @@
         <module>agentscope-extensions-higress</module>
         <module>agentscope-extensions-nacos</module>
     </modules>
+
 </project>