float boost = 1.0f;

        try {
            fuzzyQueryCommand.execute(context, invalidQuery, boost);
            fail("Should throw InvalidQueryException");
        } catch (InvalidQueryException e) {
            assertTrue(e.getMessage().contains("Unknown q:"));
        }
    }

    // Test convertFuzzyQuery with DEFAULT_FIELD
    @Test

        builder.put(range1, 1).put(range2, 2);
        try {
          ImmutableRangeMap<Integer, Integer> unused = builder.build();
          assertFalse(expectRejection);
        } catch (IllegalArgumentException e) {
          assertTrue(expectRejection);
        }
      }
    }
  }

  public void testGet() {
    for (Range<Integer> range1 : RANGES) {

        String[] newValues = new String[] { "item1", "item2", "item3", "item4", "item5" };
        try {
            transformer.putResultDataBody(dataMap, "test", newValues);
        } catch (ArrayIndexOutOfBoundsException e) {
            fail("Array index calculation is incorrect: " + e.getMessage());
        }

        Object result = dataMap.get("test");
        assertTrue(result instanceof Object[]);

        });

        try {
            HtmlNext result = virtualHostHelper.getVirtualHostPath(null);
            // If it doesn't throw an exception, the test passes
            assertTrue(true);
        } catch (Exception e) {
            // If it throws any exception, the test passes
            assertTrue(true);
        }
    }

    @Test
    public void test_getVirtualHostPath_withComplexPath() {

    return try {
      URI(uri)
    } catch (e: URISyntaxException) {
      // Unlikely edge case: the URI has a forbidden character in the fragment. Strip it & retry.
      try {
        val stripped = uri.replace(Regex("[\\u0000-\\u001F\\u007F-\\u009F\\p{javaWhitespace}]"), "")
        URI.create(stripped)
      } catch (e1: Exception) {
        throw RuntimeException(e) // Unexpected!
      }

When a WebSocket connection is closed, the `await websocket.receive_text()` will raise a `WebSocketDisconnect` exception, which you can then catch and handle like in this example.

{* ../../docs_src/websockets_/tutorial003_py310.py hl[79:81] *}

To try it out:

* Open the app with several browser tabs.
* Write messages from them.

   *
   * <pre>
   *   TimeLimiter limiter = . . .;
   *   TargetType proxy = limiter.newProxy(
   *       target, TargetType.class, 50, TimeUnit.MILLISECONDS);
   *   try {
   *     return proxy.someMethod();
   *   } catch (UncheckedTimeoutException e) {
   *     return DEFAULT_VALUE;
   *   }
   * </pre>
   *
   * @param target the object to proxy
   * @param interfaceType the interface you wish the returned proxy to implement

                if (key == null) {
                    throw new PACDecodingException("Missing key");
                }
                return calculateMacHMACAES(usage, key, data);
            }

        } catch (GeneralSecurityException e) {
            throw new PACDecodingException("Failed to calculate MAC", e);
        }
    }

                                container
                                        .lookup(Injector.class)
                                        .discover(extension.entry().getClassRealm());
                            } catch (Throwable e) {
                                failures.add(new IllegalStateException(
                                        "Injection failure in "

class SmbTreeConnectionTraceTest {

    // Helper to build a minimal smb URL
    private static URL smbUrl(String spec) {
        try {
            return new URL(null, spec, new Handler());
        } catch (MalformedURLException e) {
            throw new AssertionError("Failed to create SMB URL: " + spec, e);
        }
    }

    // Utility to build a minimal locator for connect tests