import java.io.InputStream;

/**
 * A wrapper for an {@link InputStream} that ignores the {@link #close()} method call.
 * This can be useful when you want to prevent the underlying input stream from being closed.
 *
 * <p>All other methods delegate to the wrapped input stream.</p>
 *
 */
public class IgnoreCloseInputStream extends InputStream {

    /** The wrapped input stream. */
    private InputStream inputStream;

    /**

                logger.debug("Script raised JobProcessingException", e);
            }
            throw e;
        } catch (final Exception e) {
            // Log and return null for other exceptions to maintain backward compatibility
            logger.warn("Failed to evaluate Groovy script: template={}, parameters={}", template, safeParamMap, e);
            return null;
        } finally {

                 * returned by the Node Status. A new NbtAddress object should not be
                 * created for it because the original is potentially being actively
                 * referenced by other objects. We must populate the existing object's
                 * data explicitly (and carefully).
                 */
                if (!addrFound && queryAddress.hostName.hexCode == hexCode

 * This interface provides common functionality for requests that need to specify
 * and validate remote repositories for artifact resolution, dependency collection,
 * model building, and other Maven operations.
 *
 * <p>Implementations of this interface can specify a list of remote repositories
 * to be used during the operation. If no repositories are specified (null),

import org.eclipse.aether.repository.WorkspaceReader;
import org.eclipse.aether.repository.WorkspaceRepository;

import static java.util.Objects.requireNonNull;

/**
 * A maven workspace reader that delegates to a chain of other readers, effectively aggregating their contents.
 * <p>
 * This class, while technically is not immutable, should be considered as such once set up. If not mutated, it is also

    @Test
    @DisplayName("Should maintain SMB2 flag consistency")
    void testSMB2FlagConsistency() {
        // SMB1 should not be SMB2
        assertFalse(DialectVersion.SMB1.isSMB2());

        // All other versions should be SMB2
        for (DialectVersion version : DialectVersion.values()) {
            if (version != DialectVersion.SMB1) {
                assertTrue(version.isSMB2(), "Version " + version + " should be SMB2");

   * method will have no effect.
   *
   * @return {@code true} if the network was modified as a result of this call
   * @throws IllegalArgumentException if {@code edge} already exists in the graph and connects some
   *     other endpoint pair that is not equal to {@code endpoints}
   * @throws IllegalArgumentException if the introduction of the edge would violate {@link
   *     #allowsParallelEdges()} or {@link #allowsSelfLoops()}

      return standardRemoveAll(c);
    }

    @Override
    public boolean retainAll(Collection<?> c) {
      return standardRetainAll(c);
    }
  }

  /** The inverse of any other {@code AbstractBiMap} subclass. */
  private static final class Inverse<K extends @Nullable Object, V extends @Nullable Object>
      extends AbstractBiMap<K, V> {
    Inverse(Map<K, V> backward, AbstractBiMap<V, K> forward) {

        void testEquals() {
            testBlock.setMid(0x1234);

            TestServerMessageBlock other = new TestServerMessageBlock(mockConfig);
            other.setMid(0x1234);

            assertTrue(testBlock.equals(other));

            other.setMid(0x5678);
            assertFalse(testBlock.equals(other));

            assertFalse(testBlock.equals(null));

        ? EMPTY
        : new ImmutableLongArray(array, start + startIndex, start + endIndex);
  }

  @IgnoreJRERequirement // used only from APIs that use streams
  /*
   * We declare this as package-private, rather than private, to avoid generating a synthetic
   * accessor method (under -target 8) that would lack the Android flavor's @IgnoreJRERequirement.
   */
  Spliterator.OfLong spliterator() {