@ExtendWith(MockitoExtension.class)
class SmbWatchHandleImplTest {

    @Mock
    SmbFileHandleImpl handle;

    @Mock
    SmbTreeHandleImpl tree;

    // Prepare SMB2 flow with a given response
    private void setupSmb2(NotifyResponse resp, byte[] fileId) throws Exception {
        when(handle.isValid()).thenReturn(true);
        when(handle.getTree()).thenReturn(tree);
        when(tree.isSMB2()).thenReturn(true);

 */
@Deprecated(since = "4.0.0")
class FileToRawModelMerger extends MavenMerger {

    @Override
    protected void mergeBuild_Extensions(
            Build.Builder builder, Build target, Build source, boolean sourceDominant, Map<Object, Object> context) {
        // don't merge
    }

    @Override
    protected void mergeBuildBase_Resources(
            BuildBase.Builder builder,
            BuildBase target,

    /**
     * Creates a new {@code ProjectModelResolverTest} instance.
     */
    ProjectModelResolverTest() {
        super();
    }

    @Test
    void testResolveParentThrowsUnresolvableModelExceptionWhenNotFound() throws Exception {
        final Parent parent = new Parent();
        parent.setGroupId("org.apache");
        parent.setArtifactId("apache");

        @Override
        public void delay(int type) {
        }

        public void delayBeforeProcessing() {
        }

        public void delayAfterProcessing() {
        }

        public void delayAtNoUrlInQueue() {
        }

        public void delayForWaitingNewUrl() {
        }
    }

    /**
     * Test default constructor

            return this.command;
        }

        @Override
        public void setCommand(int command) {
            this.command = command;
        }

        @Override
        public void setUid(int uid) {
            this.uid = uid;
        }

        @Override
        public void setExtendedSecurity(boolean extendedSecurity) {
            this.extendedSecurity = extendedSecurity;

      }
    }
  }

  public void testDrainOverflow() throws InterruptedException {
    Queues.drain(new SynchronousQueue<>(), new ArrayList<>(), /* numElements= */ 0, MAX_DURATION);
  }

  public void testDrainUninterruptiblyOverflow() {
    Queues.drainUninterruptibly(
        new SynchronousQueue<>(), new ArrayList<>(), /* numElements= */ 0, MAX_DURATION);
  }

  public void testZeroElements() throws Exception {

 */
public interface BuildEventListener {

    void sessionStarted(ExecutionEvent event);

    void projectStarted(String projectId);

    void projectLogMessage(String projectId, String event);

    void projectFinished(String projectId);

    void executionFailure(String projectId, boolean halted, String exception);

    void mojoStarted(ExecutionEvent event);

    void finish(int exitCode) throws Exception;

    /** The current page number. */
    private int currentPageNumber;

    /** The ID of the Kuromoji dictionary. */
    public String id;

    /**
     * Clears the pager fields.
     */
    public void clear() {
        allRecordCount = 0;
        allPageCount = 0;
        existPrePage = false;
        existNextPage = false;
        pageSize = getDefaultPageSize();

        void createResponse_nullContext_throws() {
            // Arrange
            Smb2LogoffRequest req = newRequest();

            // Act/Assert
            assertThrows(NullPointerException.class, () -> req.createResponse(null, req));
        }

        @Test
        @DisplayName("createResponse tolerates null request parameter")
        void createResponse_nullRequest_ok() {

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);...