grpc: Adjust metadata names

Signed-off-by: Johannes Zottele <[email protected]>

Author: Jozott00

grpc/grpc-core/src/commonMain/kotlin/kotlinx/rpc/grpc/ClientInterceptor.kt

@@ -10,10 +10,10 @@ import kotlinx.rpc.grpc.internal.MethodDescriptor
 
 public interface ClientCallScope<Request, Response> {
     public val method: MethodDescriptor<Request, Response>
-    public val metadata: GrpcMetadata
+    public val requestHeaders: GrpcMetadata
     public val callOptions: GrpcCallOptions
-    public fun onHeaders(block: (GrpcMetadata) -> Unit)
-    public fun onClose(block: (Status, GrpcMetadata) -> Unit)
+    public fun onHeaders(block: (responseHeaders: GrpcMetadata) -> Unit)
+    public fun onClose(block: (closeStatus: Status, responseTrailers: GrpcMetadata) -> Unit)
     public fun cancel(message: String, cause: Throwable? = null): Nothing
     public fun proceed(request: Flow<Request>): Flow<Response>
 }

grpc/grpc-core/src/commonMain/kotlin/kotlinx/rpc/grpc/internal/suspendClientCalls.kt

@@ -147,7 +147,7 @@ private fun <Request, Response> GrpcClient.rpcImpl(
     val clientCallScope = ClientCallScopeImpl(
         client = this,
         method = descriptor,
-        metadata = trailers,
+        requestHeaders = trailers,
         callOptions = callOptions,
     )
     return clientCallScope.proceed(request)
@@ -205,7 +205,7 @@ internal class Ready(private val isReallyReady: () -> Boolean) {
 private class ClientCallScopeImpl<Request, Response>(
     val client: GrpcClient,
     override val method: MethodDescriptor<Request, Response>,
-    override val metadata: GrpcMetadata,
+    override val requestHeaders: GrpcMetadata,
     override val callOptions: GrpcCallOptions,
 ) : ClientCallScope<Request, Response> {
 
@@ -250,7 +250,7 @@ private class ClientCallScopeImpl<Request, Response>(
             val responses = Channel<Response>(1)
             val ready = Ready { call.isReady() }
 
-            call.start(channelResponseListener(responses, ready), metadata)
+            call.start(channelResponseListener(responses, ready), requestHeaders)
 
             suspend fun Flow<Request>.send() {
                 if (method.type == MethodType.UNARY || method.type == MethodType.SERVER_STREAMING) {