Improve suspend overloads for kotlin clients

Author: slinkydeveloper

client-kotlin/src/main/kotlin/dev/restate/client/kotlin/ingress.kt

@@ -15,7 +15,8 @@ import dev.restate.client.SendResponse
 import dev.restate.common.Output
 import dev.restate.common.Request
 import dev.restate.common.WorkflowRequest
-import dev.restate.serde.Serde
+import dev.restate.serde.TypeTag
+import dev.restate.serde.kotlinx.typeTag
 import kotlin.time.Duration
 import kotlin.time.toJavaDuration
 import kotlinx.coroutines.future.await
@@ -71,11 +72,18 @@ suspend fun <Req, Res> Client.submitSuspend(
 }
 
 suspend fun <T : Any> Client.AwakeableHandle.resolveSuspend(
-    serde: Serde<T>,
+    typeTag: TypeTag<T>,
     payload: T,
     options: ClientRequestOptions = ClientRequestOptions.DEFAULT
 ): ClientResponse<Void> {
-  return this.resolveAsync(serde, payload, options).await()
+  return this.resolveAsync(typeTag, payload, options).await()
+}
+
+suspend inline fun <reified T : Any> Client.AwakeableHandle.resolveSuspend(
+    payload: T,
+    options: ClientRequestOptions = ClientRequestOptions.DEFAULT
+): ClientResponse<Void> {
+  return this.resolveSuspend(typeTag<T>(), payload, options)
 }
 
 suspend fun Client.AwakeableHandle.rejectSuspend(

client/src/main/java/dev/restate/client/Client.java

@@ -12,7 +12,6 @@
 import dev.restate.common.Request;
 import dev.restate.common.Target;
 import dev.restate.common.WorkflowRequest;
-import dev.restate.serde.Serde;
 import dev.restate.serde.SerdeFactory;
 import dev.restate.serde.TypeTag;
 import java.time.Duration;
@@ -135,19 +134,19 @@ default <T> ClientResponse<Void> resolve(Class<T> clazz, @NonNull T payload) {
 
     /** Same as {@link #resolve(Class, Object)} but async with options. */
     default <T> CompletableFuture<ClientResponse<Void>> resolveAsync(
-            Class<T> clazz, @NonNull T payload, ClientRequestOptions options) {
+        Class<T> clazz, @NonNull T payload, ClientRequestOptions options) {
       return this.resolveAsync(TypeTag.of(clazz), payload, options);
     }
 
     /** Same as {@link #resolve(TypeTag, Object)} but async. */
     default <T> CompletableFuture<ClientResponse<Void>> resolveAsync(
-            Class<T> clazz, @NonNull T payload) {
+        Class<T> clazz, @NonNull T payload) {
       return resolveAsync(TypeTag.of(clazz), payload, ClientRequestOptions.DEFAULT);
     }
 
     /** Same as {@link #resolve(TypeTag, Object)} with options. */
     default <T> ClientResponse<Void> resolve(
-            Class<T> clazz, @NonNull T payload, ClientRequestOptions options) {
+        Class<T> clazz, @NonNull T payload, ClientRequestOptions options) {
       return resolve(TypeTag.of(clazz), payload, options);
     }