return byteSink.wasStreamOpened();
  }

  @Override
  public boolean wasStreamClosed() {
    return byteSink.wasStreamClosed();
  }

  @Override
  public Writer openStream() throws IOException {
    // using TestByteSink's output stream to get option behavior, so flush to it on every write
    return new FilterWriter(new OutputStreamWriter(byteSink.openStream(), UTF_8)) {
      @Override
      public void write(int c) throws IOException {

    return byteSink.wasStreamOpened();
  }

  @Override
  public boolean wasStreamClosed() {
    return byteSink.wasStreamClosed();
  }

  @Override
  public Writer openStream() throws IOException {
    // using TestByteSink's output stream to get option behavior, so flush to it on every write
    return new FilterWriter(new OutputStreamWriter(byteSink.openStream(), UTF_8)) {
      @Override
      public void write(int c) throws IOException {

 *
 * @author mbechler
 *
 * <p>This interface is intended for internal use.</p>
 */
public interface SmbTreeInternal extends SmbTree {

    /**
     * Connects and performs logon to the tree using the specified context
     * @param tf the CIFS context to use for connection
     * @throws SmbException if an SMB error occurs during connection
     */
    @Deprecated

     */
    @Nonnull
    Toolchain createToolchain(@Nonnull ToolchainModel model) throws ToolchainFactoryException;

    /**
     * Creates a default toolchain instance using system defaults.
     *
     * @return Optional containing the default toolchain if available
     * @throws ToolchainFactoryException if default toolchain creation fails
     */
    @Nonnull

 */
package org.codelibs.fess.opensearch.config.exentity;

import java.util.Arrays;

import org.codelibs.fess.opensearch.config.bsentity.BsRelatedQuery;

/**
 * @author ESFlute (using FreeGen)
 */
public class RelatedQuery extends BsRelatedQuery {

    private static final long serialVersionUID = 1L;

    public String getId() {
        return asDocMeta().id();
    }

import org.apache.maven.api.annotations.ThreadSafe;

/**
 * Marker interface for all services provided by the {@link Session}.
 * <p>
 * Services can be retrieved from the session using the
 * {@link Session#getService(Class)} method.
 *
 * @since 4.0.0
 * @see Session#getService(Class)
 */
@Experimental
@ThreadSafe

  command: server http://minio{1...4}/data{1...3}
  env_file:
    - ./minio.env
  expose:
    - "9000"
    - "9001"

# starts 4 docker containers running minio server instances.
# using nginx reverse proxy, load balancing, you can access
# it through port 9000.
services:
  minio1:
    <<: *minio-common
    hostname: minio1
    volumes:
      - data1-1:/data1
      - data1-2:/data2

 *
 * <p>Default settings and array settings can be customized using:</p>
 * <ul>
 *   <li>{@link #defaultSettings()}</li>
 *   <li>{@link #defaultArraySettings()}</li>
 * </ul>
 *
 * <p>Index settings can be loaded from a JSON file using:</p>
 * <ul>
 *   <li>{@link #loadIndexSettings()}</li>
 * </ul>
 *
 * <p>A builder for SuggestSettings can be obtained using:</p>
 * <ul>
 *   <li>{@link #builder()}</li>
 * </ul>
 *

        }

    }

    /**
     * Internal search method that executes the actual search query.
     *
     * This method performs the search using the rank fusion processor and may retry
     * with OR operator if the hit count is below the configured minimum threshold.
     *
     * @param query The search query string
     * @param params The search request parameters

   * #getOnlyElement(Iterable)} or {@link #getOnlyElement(Iterable, Object)} instead.
   *
   * <p><b>{@code Stream} equivalent:</b> {@code stream.findFirst().orElse(defaultValue)}
   *
   * <p><b>Java 21+ users:</b> if {code iterable} is a {@code SequencedCollection} (e.g., any list),