Move the initial call.request

taer · taer · commit 75b5ea5d4fe0 · 2021-08-12T13:53:17.000-05:00
diff --git a/stub/src/main/java/io/grpc/kotlin/ServerCalls.kt b/stub/src/main/java/io/grpc/kotlin/ServerCalls.kt
@@ -223,7 +223,6 @@ object ServerCalls {
         "requests flow can only be collected once"
       }
 
-      call.request(1)
       try {
         for (request in requestsChannel) {
           emit(request)
@@ -256,6 +255,8 @@ object ServerCalls {
       mutex.withLock { call.close(closeStatus, trailers) }
     }
 
+    call.request(1)
+
     return object: ServerCall.Listener<RequestT>() {
       var isReceiving = true
 

Original file line number	Diff line number	Diff line change
`@@ -223,7 +223,6 @@ object ServerCalls {`
`223`	`223`	`"requests flow can only be collected once"`
`224`	`224`	`}`
`225`	`225`
`226`		`- call.request(1)`
`227`	`226`	`try {`
`228`	`227`	`for (request in requestsChannel) {`
`229`	`228`	`emit(request)`
`@@ -256,6 +255,8 @@ object ServerCalls {`
`256`	`255`	`mutex.withLock { call.close(closeStatus, trailers) }`
`257`	`256`	`}`
`258`	`257`
	`258`	`+ call.request(1)`
	`259`	`+`
`259`	`260`	`return object: ServerCall.Listener<RequestT>() {`
`260`	`261`	`var isReceiving = true`
`261`	`262`