public boolean equals(@Nullable Object obj) {
    return Sets.equalsImpl(this, obj);
  }

  @Override
  public int hashCode() {
    return Sets.hashCodeImpl(this);
  }

  // This declaration is needed to make Set.iterator() and
  // ImmutableCollection.iterator() appear consistent to javac's type inference.
  @Override
  public abstract UnmodifiableIterator<E> iterator();

        }

        @Test
        @DisplayName("Should handle null buffer")
        void testReadBytesWithNullBuffer() {
            // This is expected behavior for echo request - no reading needed
            assertDoesNotThrow(() -> {
                int result = echoRequest.readBytesWireFormat(null, 0);
                assertEquals(0, result);
            });
        }
    }

    @Nested

            when(mockCtx.supportsIntegrity()).thenReturn(true);
            when(mockCtx.calculateMIC(any(byte[].class))).thenReturn(new byte[] { 42 });
            // verifyMIC returns void; no stubbing needed
            when(mockCtx.isMICAvailable()).thenReturn(true);

            // Act
            useContext(mockCtx);

            // Assert: verify key interactions and ordering where meaningful

        @Test
        @DisplayName("Should handle response at end of buffer")
        void testResponseAtEndOfBuffer() throws SMBProtocolDecodingException {
            byte[] buffer = new byte[20]; // Exact size needed
            SMBUtil.writeInt2(17, buffer, 0);
            SMBUtil.writeInt2(0, buffer, 2);
            SMBUtil.writeInt4(999, buffer, 4);
            SMBUtil.writeInt4(111, buffer, 8);

		*data = []byte(s[3:])
		return nil
	}

	return errors.New("Bytes expected")
}

func (data EncryptedData) Value() (driver.Value, error) {
	if len(data) > 0 && data[0] == 'x' {
		// needed to test failures
		return nil, errors.New("Should not start with 'x'")
	}

	// prepend asterisks
	return append([]byte("***"), data...), nil
}

type Num int64

	go func(outBlock <-chan struct{}) {
		wg.Wait()
		defer m.parent.deleteMux(true, m.ID)
		m.sendResponses(ctx, send, c, &handlerErr, outBlock)
	}(m.outBlock)

	// Remote aliveness check if needed.
	if msg.DeadlineMS == 0 || msg.DeadlineMS > uint32(4*c.clientPingInterval/time.Millisecond) {
		go func() {
			wg.Wait()
			m.checkRemoteAlive()
		}()
	}
	return &m
}

   * How is the RateLimiter designed, and why?
   *
   * The primary feature of a RateLimiter is its "stable rate", the maximum rate that it should
   * allow in normal conditions. This is enforced by "throttling" incoming requests as needed. For
   * example, we could compute the appropriate throttle time for an incoming request, and make the
   * calling thread wait for that time.
   *

### Create a Session Dependency { #create-a-session-dependency }

A **`Session`** is what stores the **objects in memory** and keeps track of any changes needed in the data, then it **uses the `engine`** to communicate with the database.

    @Test
    @DisplayName("Test readBytesWireFormat with minimum buffer size")
    void testReadBytesWireFormatMinimumBufferSize() throws SMBProtocolDecodingException {
        byte[] buffer = new byte[2]; // Minimum size needed for structure size
        int bufferIndex = 0;

        SMBUtil.writeInt2(2, buffer, bufferIndex);

        int result = response.readBytesWireFormat(buffer, bufferIndex);

        assertEquals(2, result);

        byte[] buffer = new byte[testString.length() * 2 + 2 + 1]; // +1 for alignment
        int len = smb.writeString(testString, buffer, 1);
        // When dstIndex=1 and headerStart=1, (1-1)%2=0, no alignment padding needed
        // Length is string bytes (15*2) + 2 null terminators = 32
        assertEquals(testString.length() * 2 + 2, len);
        String readString = smb.readString(buffer, 1);
        assertEquals(testString, readString);