diff --git a/stub/src/main/java/io/grpc/kotlin/ServerCalls.kt b/stub/src/main/java/io/grpc/kotlin/ServerCalls.kt
index c3c3a7a2..8f08a5a0 100644
--- a/stub/src/main/java/io/grpc/kotlin/ServerCalls.kt
+++ b/stub/src/main/java/io/grpc/kotlin/ServerCalls.kt
@@ -222,7 +222,6 @@ object ServerCalls {
         "requests flow can only be collected once"
       }
 
-      call.request(1)
       try {
         for (request in requestsChannel) {
           emit(request)
@@ -268,6 +267,8 @@ object ServerCalls {
       mutex.withLock { call.close(closeStatus, trailers) }
     }
 
+    call.request(1)
+
     return object: ServerCall.Listener<RequestT>() {
       var isReceiving = true