public void insert(FavoriteLog entity) {
        doInsert(entity, null);
    }

    public void insert(FavoriteLog entity, RequestOptionCall<IndexRequestBuilder> opLambda) {
        entity.asDocMeta().indexOption(opLambda);
        doInsert(entity, null);
    }

    public void update(FavoriteLog entity) {
        doUpdate(entity, null);
    }

    public void insert(Group entity) {
        doInsert(entity, null);
    }

    public void insert(Group entity, RequestOptionCall<IndexRequestBuilder> opLambda) {
        entity.asDocMeta().indexOption(opLambda);
        doInsert(entity, null);
    }

    public void update(Group entity) {
        doUpdate(entity, null);
    }

    }

    @Test
    void testReadParameterWordsWireFormat_InvalidDialect() {
        byte[] paramWords = new byte[2];
        paramWords[0] = 11; // dialectIndex > 10

        int bytesRead = response.readParameterWordsWireFormat(paramWords, 0);

        assertEquals(2, bytesRead);
        assertEquals(11, response.dialectIndex);
    }

    @Test

        @Test
        @DisplayName("Should initialize with SMB2_LOCK command")
        void testCommandInitialization() {
            Smb2LockRequest lockRequest = new Smb2LockRequest(mockConfig, testFileId, testLocks);
            assertNotNull(lockRequest);
        }

        @Test
        @DisplayName("Should accept null file ID in constructor")
        void testConstructorWithNullFileId() {

  public void testOf0() {
    assertThat(ImmutableLongArray.of().asList()).isEmpty();
  }

  public void testOf1() {
    assertThat(ImmutableLongArray.of(0).asList()).containsExactly(0L);
  }

  public void testOf2() {
    assertThat(ImmutableLongArray.of(0, 1).asList()).containsExactly(0L, 1L).inOrder();
  }

  public void testOf3() {

    @Mock
    private NdrObject mockNdrObject;

    private MsrpcQueryInformationPolicy queryPolicy;

    @BeforeEach
    void setUp() {
        // Setup is done through individual test methods
    }

    @Test
    void constructor_shouldInitializeWithValidParameters() {
        // Arrange
        short level = 3;

        // Act

synchronized class SystemStreamLog implements Log { public void SystemStreamLog(); public void debug(CharSequence); public void debug(CharSequence, Throwable); public void debug(Throwable); public void info(CharSequence); public void info(CharSequence, Throwable); public void info(Throwable); public void warn(CharSequence); public void warn(CharSequence, Throwable); public void warn(Throwable); public void error(CharSequence); public void error(CharSequence, Throwable); public void error(Throwable);...

  private static class DefaultService extends AbstractIdleService {
    @Override
    protected void startUp() throws Exception {}

    @Override
    protected void shutDown() throws Exception {}
  }

  public void testFunctionalServiceStartStop() {
    AbstractIdleService service = new DefaultService();
    service.startAsync().awaitRunning();

    
    public void recordRegistration() { registrationsActive.incrementAndGet(); }
    public void recordUnregistration() { registrationsActive.decrementAndGet(); }
    public void recordNotification() { notificationsReceived.incrementAndGet(); }
    public void recordFailover() { failoverEvents.incrementAndGet(); }
    public void recordHeartbeat() { heartbeatsSent.incrementAndGet(); }

            }
            return encodedSize;
        }

        public void setEncodedSize(int size) {
            this.encodedSize = size;
        }

        public void setThrowOnEncode(boolean throwOnEncode) {
            this.throwOnEncode = throwOnEncode;
        }

        public void setThrowOnSize(boolean throwOnSize) {
            this.throwOnSize = throwOnSize;
        }