Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 780 for upstream (0.03 sec)

  1. android/guava/src/com/google/common/collect/FluentIterable.java

       * elements.
       *
       * <p><b>{@code Stream} equivalent:</b> if the source iterable has only a single element {@code
       * e}, use {@code Stream.generate(() -> e)}. Otherwise, collect your stream into a collection and
       * use {@code Stream.generate(() -> collection).flatMap(Collection::stream)}.
       */
      public final FluentIterable<E> cycle() {
        return from(Iterables.cycle(getDelegate()));
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 35.3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/FluentIterable.java

       * elements.
       *
       * <p><b>{@code Stream} equivalent:</b> if the source iterable has only a single element {@code
       * e}, use {@code Stream.generate(() -> e)}. Otherwise, collect your stream into a collection and
       * use {@code Stream.generate(() -> collection).flatMap(Collection::stream)}.
       */
      public final FluentIterable<E> cycle() {
        return from(Iterables.cycle(getDelegate()));
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/MockSocketHandler.kt

      ) = apply {
        actions += { stream ->
          stream.sink.writeUtf8(s)
          stream.sink.flush()
          responseSent.countDown()
        }
      }
    
      fun exhaustResponse() =
        apply {
          actions += { stream -> stream.sink.close() }
        }
    
      fun sleep(
        duration: Long,
        unit: TimeUnit,
      ) = apply {
        actions += { Thread.sleep(unit.toMillis(duration)) }
      }
    
      override fun handle(socket: Socket) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/admin/fileconfig/AdminFileconfigAction.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.app.web.admin.fileconfig;
    
    import static org.codelibs.core.stream.StreamUtil.split;
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/app/web/admin/webconfig/AdminWebconfigAction.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.app.web.admin.webconfig;
    
    import static org.codelibs.core.stream.StreamUtil.split;
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 21K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/opensearch/user/exentity/User.java

            asDocMeta().id(id);
        }
    
        @Override
        public String[] getRoleNames() {
            return stream(getRoles()).get(stream -> stream.map(this::decode).toArray(n -> new String[n]));
        }
    
        @Override
        public String[] getGroupNames() {
            return stream(getGroups()).get(stream -> stream.map(this::decode).toArray(n -> new String[n]));
        }
    
        private String decode(final String value) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Mar 15 06:53:53 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/dataconfig/AdminDataconfigAction.java

     */
    package org.codelibs.fess.app.web.admin.dataconfig;
    
    import static org.codelibs.core.stream.StreamUtil.split;
    import static org.codelibs.core.stream.StreamUtil.stream;
    
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 19.9K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/core/io/CopyUtil.java

        // from InputStream to OutputStream
        //
        /**
         * Copies from an input stream to an output stream.
         * <p>
         * Neither the input stream nor the output stream is closed.
         * </p>
         *
         * @param in the input stream (must not be {@literal null})
         * @param out the output stream (must not be {@literal null})
         * @return the number of bytes copied
         */
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  9. guava/src/com/google/common/io/ByteStreams.java

      /**
       * Copies all bytes from the input stream to the output stream. Does not close or flush either
       * stream.
       *
       * <p><b>Java 9 users and later:</b> this method should be treated as deprecated; use the
       * equivalent {@link InputStream#transferTo} method instead.
       *
       * @param from the input stream to read from
       * @param to the output stream to write to
       * @return the number of bytes copied
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/app/web/base/login/SamlCredential.java

                    permissionSet.add(systemHelper.getSearchRoleByUser(nameId));
                    stream(groups).of(stream -> stream.forEach(s -> permissionSet.add(systemHelper.getSearchRoleByGroup(s))));
                    stream(roles).of(stream -> stream.forEach(s -> permissionSet.add(systemHelper.getSearchRoleByRole(s))));
                    permissions = permissionSet.toArray(new String[permissionSet.size()]);
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 8.4K bytes
    - Viewed (0)
Back to top