Commit 26d254d
Bigtable - improvement: Rewrite ReframingResponseObserver (googleapis#2925)
The new version uses atomics to ensure mutual exclusion instead of synchronization.
This allows the delivery loop to be simpler since there is no need to need to defer actions until after exiting the synchronization.
Also, move all interactions with the Reframer to the delivery loop, which ensures proper error handling if the Reframer detects an error.1 parent fe50852 commit 26d254d
File tree
3 files changed
+178
-193
lines changed- google-cloud-bigtable/src
- main/java/com/google/cloud/bigtable/gaxx/reframing
- test/java/com/google/cloud/bigtable/gaxx
- reframing
- testing
3 files changed
+178
-193
lines changed
0 commit comments