Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 878 for Stream (0.09 sec)

  1. src/main/java/org/codelibs/fess/entity/FacetQueryView.java

        @PostConstruct
        public void init() {
            final String filetypeField = ComponentUtil.getFessConfig().getIndexFieldFiletype();
            final Collection<String> values = queryMap.values();
            if (values.stream().anyMatch(s -> s.startsWith(filetypeField))) {
                final ResourceBundle resources = ResourceBundle.getBundle("fess_label", Locale.ENGLISH);
                final String[] fileTypes = ComponentUtil.getFileTypeHelper().getTypes();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 3K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb/SmbPipeHandleInternal.java

         */
        byte[] getSessionKey () throws CIFSException;
    
    
        /**
         * 
         * @return this pipe's input stream
         * @throws SmbException
         */
        @Override
        SmbPipeInputStream getInput () throws CIFSException;
    
    
        /**
         * 
         * @return this pipe's output stream
         * @throws SmbException
         * @throws
         */
        @Override
        SmbPipeOutputStream getOutput () throws CIFSException;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 2.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/math/StatsAccumulator.java

    import static java.lang.Double.isNaN;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import java.util.Iterator;
    import java.util.stream.DoubleStream;
    import java.util.stream.IntStream;
    import java.util.stream.LongStream;
    
    /**
     * A mutable object which accumulates double values and tracks some basic statistics over all the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 23 16:45:30 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/primitives/ImmutableIntArrayTest.java

        assertThat(count.get()).isEqualTo(4);
      }
    
      public void testStream() {
        ImmutableIntArray.of().stream().forEach(i -> fail());
        ImmutableIntArray.of(0, 1, 3).subArray(1, 1).stream().forEach(i -> fail());
        assertThat(ImmutableIntArray.of(0, 1, 3).stream().toArray()).isEqualTo(new int[] {0, 1, 3});
      }
    
      public void testSubArray() {
        ImmutableIntArray iia0 = ImmutableIntArray.of();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/primitives/ImmutableDoubleArrayTest.java

        assertThat(count.get()).isEqualTo(4);
      }
    
      public void testStream() {
        ImmutableDoubleArray.of().stream().forEach(i -> fail());
        ImmutableDoubleArray.of(0, 1, 3).subArray(1, 1).stream().forEach(i -> fail());
        assertThat(ImmutableDoubleArray.of(0, 1, 3).stream().toArray())
            .isEqualTo(new double[] {0, 1, 3});
      }
    
      public void testSubArray() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/RouteFailureTest.kt

          client.newBuilder()
            .fastFallback(false)
            .apply {
              retryOnConnectionFailure = false
            }
            .build()
    
        executeSynchronously(request)
          .assertFailureMatches("stream was reset: REFUSED_STREAM")
    
        assertThat(client.routeDatabase.failedRoutes).isEmpty()
        assertThat(server1.requestCount).isEqualTo(1)
        assertThat(server2.requestCount).isEqualTo(0)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue May 14 17:48:07 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  7. impl/maven-core/src/main/java/org/apache/maven/execution/ProfileActivation.java

    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.function.Predicate;
    
    import static java.util.stream.Collectors.toSet;
    
    /**
     * Container for storing the request from the user to activate or de-activate certain profiles and optionally fail the
     * build if those profiles do not exist.
     */
    public class ProfileActivation {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  8. docs/bucket/versioning/DESIGN.md

    `xl.meta` carries first 8 bytes an XL header which describes the current format and the format version,
    allowing the unmarshaller's to automatically use the right data structures to parse the subsequent content in the stream.
    
    ### v1.0
    
    | Entry     | Encoding    | Content
    | ----------|-------------|----------------------------------------
    | xlHeader  | [4]byte     | `'X', 'L', '2', ' '`
    | xlVersion | [4]byte     | `'1', ' ', ' ', ' '`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 17 15:43:14 UTC 2022
    - 5.8K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb1/smb1/SmbFileOutputStream.java

            }
        }
    
    /**
     * Closes this output stream and releases any system resources associated
     * with it.
     *
     * @throws IOException if a network error occurs
     */
    
        public void close() throws IOException {
            file.close();
            tmp = null;
        }
    
    /**
     * Writes the specified byte to this file output stream.
     *
     * @throws IOException if a network error occurs
     */
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 9.2K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/api/admin/dict/stopwords/ApiAdminDictStopwordsAction.java

    import static org.codelibs.fess.app.web.admin.dict.stopwords.AdminDictStopwordsAction.createStopwordsItem;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.fess.app.pager.StopwordsPager;
    import org.codelibs.fess.app.service.StopwordsService;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 7.2K bytes
    - Viewed (0)
Back to top