ArtifactRepository localRepository)
            throws ArtifactDeploymentException;

    /**
     * Deploy an artifact from a particular file.
     *
     * @param source the file to deploy
     * @param artifact the artifact definition
     * @param deploymentRepository the repository to deploy to
     * @param localRepository the local repository to install into

  }

  @Test
  @Throws(Exception::class)
  fun timeDurationTruncatedToMaxValue() {
    val cacheControl =
      CacheControl
        .Builder()
        .maxAge(365 * 100, TimeUnit.DAYS) // Longer than Integer.MAX_VALUE seconds.
        .build()
    assertThat(cacheControl.maxAgeSeconds).isEqualTo(Int.MAX_VALUE)
  }

  @Test
  @Throws(Exception::class)
  fun secondsMustBeNonNegative() {

        @Inject
        ReactorReaderSpy(Lookup lookup) {
            this.lookup = lookup;
        }

        @Override
        public void init(Context context) throws Exception {}

        @Override
        public void onEvent(Object event) throws Exception {
            if (event instanceof ExecutionEvent executionEvent) {
                ReactorReader reactorReader = lookup.lookup(ReactorReader.class);

   *
   * @param it an iterator of I/O suppliers that will provide each substream
   */
  public MultiInputStream(Iterator<? extends ByteSource> it) throws IOException {
    this.it = checkNotNull(it);
    advance();
  }

  @Override
  public void close() throws IOException {
    if (in != null) {
      try {
        in.close();
      } finally {
        in = null;
      }
    }
  }

    @Nested
    @DisplayName("Decoding Tests")
    class DecodingTests {

        @Test
        @DisplayName("Should decode single hash algorithm with salt")
        void testDecodeSingleHashAlgoWithSalt() throws SMBProtocolDecodingException {
            SMBUtil.writeInt2(1, buffer, 0);
            SMBUtil.writeInt2(4, buffer, 2);
            SMBUtil.writeInt2(PreauthIntegrityNegotiateContext.HASH_ALGO_SHA512, buffer, 4);

     * Handles document transformation, field addition, and batched indexing.
     *
     * @param paramMap the data store parameters
     * @param dataMap the document data to store
     * @throws DataStoreException if required fields are missing or other errors occur
     */
    @Override
    public void store(final DataStoreParams paramMap, final Map<String, Object> dataMap) {

    @Resource
    private ScheduledJobService scheduledJobService;

    /**
     * Index page (not supported for API).
     *
     * @return throws UnsupportedOperationException
     */
    @Execute
    public HtmlResponse index() {
        throw new UnsupportedOperationException("index() is not supported in API. Use the admin UI instead.");
    }

    /**
     * Starts a scheduled job by ID.

import java.io.StringReader;

import org.junit.Test;

/**
 * @author koichik
 */
public class LineIteratorTest {

    /**
     * @throws Exception
     */
    @Test
    public void test() throws Exception {
        final StringReader reader = new StringReader("aaa\nbbb\nccc\n");
        final LineIterator it = new LineIterator(reader);
        assertThat(it.hasNext(), is(true));

    }

    @ParameterizedTest
    @EnumSource(SubjectVariant.class)
    @DisplayName("getSubject: caches results and refresh resets cache")
    void testGetSubjectLoginFailuresCacheAndRefresh(SubjectVariant variant) throws Exception {
        JAASAuthenticator auth = buildAuthenticator(variant);

        // First call attempts a JAAS login; behavior depends on JAAS configuration
        Subject first = auth.getSubject();

    SmbPipeHandleImpl handle;

    @Mock
    SmbTreeHandleImpl tree;

    @Mock
    SmbNamedPipe pipe;

    @Mock
    SmbFileHandleImpl fileHandle;

    private SmbPipeOutputStream newStream() throws CIFSException {
        // Arrange common constructor collaborators to avoid touching network/state
        when(handle.getPipe()).thenReturn(pipe);
        when(tree.isSMB2()).thenReturn(true);