This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-grpc.git
The following commit(s) were added to refs/heads/main by this push:
new b9313084 mark headers field as volatile (#821)
b9313084 is described below
commit b93130840a1f5cec9ce7b52102e2e0856d3615f2
Author: PJ Fanning <[email protected]>
AuthorDate: Tue Aug 4 09:41:44 2026 +0100
mark headers field as volatile (#821)
---
.../main/scala/org/apache/pekko/grpc/internal/UnaryCallAdapter.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/runtime/src/main/scala/org/apache/pekko/grpc/internal/UnaryCallAdapter.scala
b/runtime/src/main/scala/org/apache/pekko/grpc/internal/UnaryCallAdapter.scala
index 1bff5440..b351769b 100644
---
a/runtime/src/main/scala/org/apache/pekko/grpc/internal/UnaryCallAdapter.scala
+++
b/runtime/src/main/scala/org/apache/pekko/grpc/internal/UnaryCallAdapter.scala
@@ -63,7 +63,7 @@ private[pekko] final class UnaryCallAdapter[Res] extends
ClientCall.Listener[Res
@InternalApi
private[pekko] final class UnaryCallWithMetadataAdapter[Res] extends
ClientCall.Listener[Res] {
private val responsePromise = Promise[GrpcSingleResponse[Res]]()
- private var headers: OptionVal[Metadata] = OptionVal.None
+ @volatile private var headers: OptionVal[Metadata] = OptionVal.None
private val trailerPromise = Promise[Metadata]()
// always invoked before message
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
