// unconsumedTimer fires.
			select {
			// Check after a second
			case <-time.After(time.Second):
				h.mutex.Unlock()
				continue

			case <-h.ctx.Done():
				h.mutex.Unlock()
				// discard result and return.
				return errHealStopSignalled

			// Timeout if no results consumed for too long.
			case <-unconsumedTimer.C:
				h.mutex.Unlock()
				return errHealIdleTimeout
			}
		}

            assertEquals("An error occurred during the deferred computation.", e.getMessage());
        }
    }

    // ============================================================
    // Edge case tests for timeout handling
    // ============================================================

    @Test
    public void test_getResponseTimeout() throws Exception {

	region := globalSite.Region()
	switch atype {
	case authTypeUnknown:
		return ErrSignatureVersionNotSupported
	case authTypeSignedV2, authTypePresignedV2:
		cred, owner, s3Err = getReqAccessKeyV2(r)
	case authTypeStreamingSigned, authTypePresigned, authTypeSigned, authTypeStreamingSignedTrailer:
		cred, owner, s3Err = getReqAccessKeyV4(r, region, serviceS3)
	case authTypeStreamingUnsignedTrailer:

   * throws} clause: Java forces us to handle an arbitrary {@link Throwable} from that method,
   * rather than just the {@link RuntimeException} or {@link Error} that should be possible. (And in
   * fact the static type of {@link Throwable} is occasionally justified even for a method with no
   * {@code throws} clause: Some such methods can in fact throw a checked exception (e.g., by

		if err != nil {
			err = msgp.WrapError(err)
			return
		}
		switch msgp.UnsafeString(field) {
		case "LimitInBytesPerSecond":
			z.LimitInBytesPerSecond, err = dc.ReadInt64()
			if err != nil {
				err = msgp.WrapError(err, "LimitInBytesPerSecond")
				return
			}
		case "CurrentBandwidthInBytesPerSecond":
			z.CurrentBandwidthInBytesPerSecond, err = dc.ReadFloat64()
			if err != nil {

	case crypto.S3:
		m[xhttp.AmzServerSideEncryption] = xhttp.AmzEncryptionAES
	case crypto.S3KMS:
		m[xhttp.AmzServerSideEncryption] = xhttp.AmzEncryptionKMS
		m[xhttp.AmzServerSideEncryptionKmsID] = kmsKeyIDFromMetadata(metadata)
		if kmsCtx, ok := metadata[crypto.MetaContext]; ok {
			m[xhttp.AmzServerSideEncryptionKmsContext] = kmsCtx
		}
	case crypto.SSEC:

        switch (action) {
        case FILE_ACTION_ADDED:
            return DirectoryChangeType.FILE_ADDED;
        case FILE_ACTION_REMOVED:
            return DirectoryChangeType.FILE_REMOVED;
        case FILE_ACTION_MODIFIED:
            return DirectoryChangeType.FILE_MODIFIED;
        case FILE_ACTION_RENAMED_OLD_NAME:
        case FILE_ACTION_RENAMED_NEW_NAME:

	var aead cipher.AEAD
	switch keyType {
	case kms.AES256:
		mac := hmac.New(sha256.New, s.key)
		mac.Write(iv)
		sealingKey := mac.Sum(nil)

		block, err := aes.NewCipher(sealingKey)
		if err != nil {
			return nil, err
		}
		aead, err = cipher.NewGCM(block)
		if err != nil {
			return nil, err
		}
	case kms.ChaCha20:
		sealingKey, err := chacha20.HChaCha20(s.key, iv)

        // Setup mock request manager with mixed case
        // LocaleUtils.toLocale is strict about case - it will throw exception for invalid format
        RequestManager mockRequestManager = createMockRequestManager("En_Us");

        // Execute
        OptionalThing<Locale> result = provider.findBusinessLocale(null, mockRequestManager);

        // Verify - invalid case format should return empty due to exception

     * For BoolQueryBuilder, adds as a should clause.
     * For DisMaxQueryBuilder, adds as a query.
     *
     * @param innerQueryBuilder the query builder to add
     * @return this instance for method chaining
     */
    public DefaultQueryBuilder add(final QueryBuilder innerQueryBuilder) {
        switch (queryType) {
        case BOOL:
            ((BoolQueryBuilder) queryBuilder).should(innerQueryBuilder);