} else {
                System.arraycopy(tmp, beg_idx, pipe_buf, 0, used);
            }
            beg_idx = 0;
            nxt_idx = used;
            tmp = null;
        }

        i = pipe_buf.length - nxt_idx;
        if (len > i) {
            System.arraycopy(b, off, pipe_buf, nxt_idx, i);
            off += i;

        assertEquals(message, exception.getMessage(), "Message should match the input.");
        assertNull(exception.getCause(), "Cause should be null for message-only constructor.");
    }

    /**
     * Test constructor DcerpcException(String msg, Throwable rootCause).
     */
    @Test
    void testConstructorWithMessageAndCause() {

    private String nativeFileSystem = "";

    /**
     * Constructs a tree connect AndX response.
     *
     * @param config the configuration to use
     * @param andx the next command in the AndX chain, or null
     */
    public SmbComTreeConnectAndXResponse(final Configuration config, final ServerMessageBlock andx) {
        super(config, andx);
    }

    /**
     * @return the service
     */
    @Override

            Stream.of(DependencyScope.values()).collect(Collectors.toMap(s -> s.id, s -> s)));

    /**
     * {@return the dependency scope for the given identifier, or {@code null} if none}.
     * The identifiers are usually in lower cases with {@code '-'} instead of {@code '_'}
     * as word separator.
     *
     * @param id the identifier of the scope (case-sensitive)
     */

                LegacyLocalRepositoryManager.overlay(localRepository, legacySupport.getRepositorySession(), repoSystem);

        InstallRequest request = new InstallRequest();

        request.setTrace(RequestTrace.newChild(null, legacySupport.getSession().getCurrentProject()));

        org.eclipse.aether.artifact.Artifact mainArtifact = RepositoryUtils.toArtifact(artifact);
        mainArtifact = mainArtifact.setFile(source);

				</button>
				<button type="submit" class="btn btn-primary">
					<em class="fa fa-search">
					<la:message key="labels.search" />
				</button>
				<la:link href="/search/advance?q=${f:u(q)}${fe:pagingQuery(null)}" styleClass="btn btn-info">
					<em class="fa fa-cog">
					<la:message key="labels.advance" />
				</la:link>
			</div>
		</div>
	</div>

     */
    protected void setupListCondition(final WebAuthenticationCB cb, final WebAuthPager webAuthenticationPager) {
        if (webAuthenticationPager.id != null) {
            cb.query().docMeta().setId_Equal(webAuthenticationPager.id);
        }
        // TODO Long, Integer, String supported only.
        // setup condition
        cb.query().addOrderBy_Hostname_Asc();

				</button>
				<button type="submit" class="btn btn-primary">
					<em class="fa fa-search">
					<la:message key="labels.search" />
				</button>
				<la:link href="/search/advance?q=${f:u(q)}${fe:pagingQuery(null)}" styleClass="btn btn-info">
					<em class="fa fa-cog">
					<la:message key="labels.advance" />
				</la:link>
			</div>
		</div>
	</div>

  private boolean methodCalled;
  private @Nullable Object methodArgument;

  @Override
  protected void setUp() throws Exception {
    bus = new EventBus();
    methodCalled = false;
    methodArgument = null;
  }

  public void testCreate() {
    Subscriber s1 = Subscriber.create(bus, this, getTestSubscriberMethod("recordingMethod"));
    assertThat(s1).isInstanceOf(Subscriber.SynchronizedSubscriber.class);

    /**
     * Session flag indicating this is a guest session
     */
    public static final int SMB2_SESSION_FLAGS_IS_GUEST = 0x1;

    /**
     * Session flag indicating this is a null/anonymous session
     */
    public static final int SMB2_SESSION_FLAGS_IS_NULL = 0x2;

    /**
     * Session flag indicating data encryption is required for this session
     */