},

        },

		return err
	}
	var state srState
	if !unlinkSelf {
		state = srState{
			Name:                    c.state.Name,
			Peers:                   updatedPeers,
			ServiceAccountAccessKey: c.state.ServiceAccountAccessKey,
		}
	}

	if err := c.saveToDisk(ctx, state); err != nil {
		return errSRBackendIssue(fmt.Errorf("unable to save cluster-replication state to drive on %s: %v", ourName, err))
	}

   */
  public static final class ValueAndCloser<V extends @Nullable Object> {

    private final State<? extends V> state;

    private ValueAndCloser(State<? extends V> state) {
      this.state = state;
    }

    /**
     * Returns the final value of the associated {@link ClosingFuture}, or throws an exception as
     * {@link Future#get()} would.
     *

*/\nexport default function removeEventListeners(reference, state) {\n  // Remove resize event listener on window\n  getWindow(reference).removeEventListener('resize', state.updateBound);\n\n  // Remove scroll event listener on scroll parents\n  state.scrollParents.forEach(target => {\n    target.removeEventListener('scroll', state.updateBound);\n  });\n\n  // Reset state\n  state.updateBound = null;\n  state.scrollParents = [];\n  state.scrollElement = null;\n  state.eventsEnabled = false;\n  return...

HSPLandroidx/lifecycle/Lifecycle$Event;->upFrom(Landroidx/lifecycle/Lifecycle$State;)Landroidx/lifecycle/Lifecycle$Event;
HSPLandroidx/lifecycle/Lifecycle$Event;->values()[Landroidx/lifecycle/Lifecycle$Event;
HSPLandroidx/lifecycle/Lifecycle$State;-><clinit>()V
HSPLandroidx/lifecycle/Lifecycle$State;-><init>(Ljava/lang/String;I)V
HSPLandroidx/lifecycle/Lifecycle$State;->values()[Landroidx/lifecycle/Lifecycle$State;

    }

    public void setState_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda) {
        setState_Terms("state", opLambda, null);
    }

    public void setState_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda, OperatorCall<BsUserCA> aggsLambda) {
        setState_Terms("state", opLambda, aggsLambda);
    }

		default:
			bts, err = msgp.Skip(bts)
			if err != nil {
				err = msgp.WrapError(err)
				return
			}
		}
	}
	o = bts
	return
}

// Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
func (z BaseOptions) Msgsize() (s int) {
	s = 1
	return
}

// DecodeMsg implements msgp.Decodable

          "name": "TestDistribution"
        }
      },
      {
        "subprojects": [
          "base-services-groovy",
          "build-cache-packaging",
          "build-operations",
          "build-state",
          "daemon-services",
          "hashing",
          "precondition-tester",
          "report-rendering",
          "service-registry-builder",
          "test-suites-base",
          "testing-jvm"

		return []madmin.KMS{}
	}

	stat, err := GlobalKMS.Status(ctx)
	if err != nil {
		kmsLogIf(ctx, err, "failed to fetch KMS status information")
		return []madmin.KMS{}
	}

	stats := make([]madmin.KMS, 0, len(stat.Endpoints))
	for endpoint, state := range stat.Endpoints {
		stats = append(stats, madmin.KMS{
			Status:   string(state),
			Endpoint: endpoint,
		})
	}