facetQueryView.init();

        // Size should remain the same
        assertEquals(firstSize, facetQueryView.getQueryMap().size());
        // But queries would be added again to FacetInfo (distinct handles duplicates)
        assertTrue(testFacetInfo.getAddedQueries().size() >= firstQueriesCount);
    }

    // Test complex scenarios
    @Test
    public void test_init_withMixedQueries() {

 * array contains information about special ASCII characters such as {@code \\t} and {@code \\n}
 * while {@link #escapeUnsafe} is overridden to handle general escaping of the form {@code \\uxxxx}.
 *
 * <p>The size of the data structure used by {@link ArrayBasedCharEscaper} is proportional to the

    }

    /**
     * @return the pipe type
     */
    @Override
    public int getPipeType() {
        return this.pipeType;
    }

    /**
     * @return a handle for interacting with the pipe
     */
    @Override
    public SmbPipeHandle openPipe() {
        return new SmbPipeHandleImpl(this);
    }

 * "different representations of the same information", since one is distinguishable from
 * <i>missing</i> information and the other is not. The {@link #convert} method handles this null
 * behavior for all converters; implementations of {@link #doForward} and {@link #doBackward} are
 * guaranteed to never be passed {@code null}, and must never return {@code null}.
 *
 * <h3>Common ways to use</h3>

            csvWriter.writeValues(list);

            badWordBhv.selectCursor(cb -> cb.query().matchAll(), new EntityRowHandler<BadWord>() {
                @Override
                public void handle(final BadWord entity) {
                    final List<String> list = new ArrayList<>();
                    addToList(list, entity.getSuggestWord());
                    try {

        if (result.hasExceptions()) {
            ExceptionHandler handler = new DefaultExceptionHandler();

            Map<String, String> references = new LinkedHashMap<>();

            List<MavenProject> failedProjects = new ArrayList<>();

            for (Throwable exception : result.getExceptions()) {
                ExceptionSummary summary = handler.handleException(exception);

    }

    @Test
    public void test_highlightedFields_withNull() {
        queryFieldConfig.highlightedFields = null;

        // When highlightedFields is null, the method should handle it gracefully
        // or throw an exception. Test the actual behavior.
        queryFieldConfig.highlightedFields(stream -> {
            // If it doesn't throw NPE, it should provide an empty stream

   * declaredType}. Example usage:
   *
   * <pre>
   * try {
   *   someMethodThatCouldThrowAnything();
   * } catch (IKnowWhatToDoWithThisException e) {
   *   handle(e);
   * } catch (Throwable t) {
   *   Throwables.propagateIfInstanceOf(t, IOException.class);
   *   Throwables.propagateIfInstanceOf(t, SQLException.class);
   *   throw Throwables.propagate(t);
   * }
   * </pre>

   * async task to do so.
   */
  inner class ReaderRunnable internal constructor(
    internal val reader: Http2Reader,
  ) : Http2Reader.Handler,
    () -> Unit {
    override fun invoke() {
      var connectionErrorCode = ErrorCode.INTERNAL_ERROR
      var streamErrorCode = ErrorCode.INTERNAL_ERROR
      var errorException: IOException? = null
      try {

        return message instanceof Smb2QueryInfoRequest
            || message instanceof Smb2SetInfoRequest
            || message instanceof Smb2QueryDirectoryRequest;
    }
}
```

### 4.5 Channel Failover Handler
```java
package jcifs.internal.smb2.multichannel;

import java.util.concurrent.*;

public class ChannelFailover {
    private final ChannelManager manager;
    private final ExecutorService executor;