Merge pull request #492 from naoh87/fix_send_headers

fix server don't sends header that client has sent
typelevel · Jan 30, 2022 · 20056a5 · 20056a5
2 parents 1cd879e + 9cbc168
commit 20056a5
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/runtime/src/main/scala/fs2/grpc/server/Fs2ServerCallHandler.scala b/runtime/src/main/scala/fs2/grpc/server/Fs2ServerCallHandler.scala
@@ -38,7 +38,7 @@ class Fs2ServerCallHandler[F[_]: Async] private (
   ): ServerCallHandler[Request, Response] = new ServerCallHandler[Request, Response] {
     def startCall(call: ServerCall[Request, Response], headers: Metadata): ServerCall.Listener[Request] = {
       val listener = dispatcher.unsafeRunSync(Fs2UnaryServerCallListener[F](call, dispatcher, options))
-      listener.unsafeUnaryResponse(headers, _ flatMap { request => implementation(request, headers) })
+      listener.unsafeUnaryResponse(new Metadata(), _ flatMap { request => implementation(request, headers) })
       listener
     }
   }
@@ -61,7 +61,7 @@ class Fs2ServerCallHandler[F[_]: Async] private (
   ): ServerCallHandler[Request, Response] = new ServerCallHandler[Request, Response] {
     def startCall(call: ServerCall[Request, Response], headers: Metadata): ServerCall.Listener[Request] = {
       val listener = dispatcher.unsafeRunSync(Fs2StreamServerCallListener[F](call, dispatcher, options))
-      listener.unsafeUnaryResponse(headers, implementation(_, headers))
+      listener.unsafeUnaryResponse(new Metadata(), implementation(_, headers))
       listener
     }
   }
@@ -71,7 +71,7 @@ class Fs2ServerCallHandler[F[_]: Async] private (
   ): ServerCallHandler[Request, Response] = new ServerCallHandler[Request, Response] {
     def startCall(call: ServerCall[Request, Response], headers: Metadata): ServerCall.Listener[Request] = {
       val listener = dispatcher.unsafeRunSync(Fs2StreamServerCallListener[F](call, dispatcher, options))
-      listener.unsafeStreamResponse(headers, implementation(_, headers))
+      listener.unsafeStreamResponse(new Metadata(), implementation(_, headers))
       listener
     }
   }