synchronized void resumeOnAddedDemand()

in cloud-spanner-r2dbc/src/main/java/com/google/cloud/spanner/r2dbc/v2/ReactiveResultSetCallback.java [94:99]

• 6 lines of code
• 3 McCabe index (conditional complexity)

  synchronized void resumeOnAddedDemand(long request) {
    if (this.paused && this.sink.requestedFromDownstream() > 0) {
      this.spannerResultSet.resume();
      this.paused = false;
    }
  }