Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 849 for upstream (0.13 sec)

  1. guava/src/com/google/common/io/LittleEndianDataOutputStream.java

    @ElementTypesAreNonnullByDefault
    public final class LittleEndianDataOutputStream extends FilterOutputStream implements DataOutput {
    
      /**
       * Creates a {@code LittleEndianDataOutputStream} that wraps the given stream.
       *
       * @param out the stream to delegate to
       */
      public LittleEndianDataOutputStream(OutputStream out) {
        super(new DataOutputStream(Preconditions.checkNotNull(out)));
      }
    
      @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 12:34:49 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/CurlHelper.java

                    logger.warn("Failed to load {}", authorities, e);
                }
            }
    
            final String[] hosts = split(ResourceUtil.getFesenHttpUrl(), ",")
                    .get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).toArray(n -> new String[n]));
            nodeManager = new NodeManager(hosts, node -> request(new CurlRequest(Method.GET, node.getUrl("/"))));
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  3. api/maven-api-core/src/main/java/org/apache/maven/api/services/Source.java

         */
        @Nullable
        Path getPath();
    
        /**
         * Creates a new byte stream to the source contents.
         * Closing the returned stream is the responsibility of the caller.
         *
         * @return a byte stream to the source contents, never {@code null}
         * @throws IOException in case of IO issue
         */
        @Nonnull
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Apr 12 10:50:18 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  4. compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/SettingsWriter.java

        void write(Writer output, Map<String, Object> options, Settings settings) throws IOException;
    
        /**
         * Writes the supplied settings to the specified byte stream. The stream will be automatically closed before the
         * method returns.
         *
         * @param output The stream to serialize the settings to, must not be {@code null}.
         * @param options The options to use for serialization, may be {@code null} to use the default values.
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/util/RenderDataUtil.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.util;
    
    import java.util.Collection;
    import java.util.List;
    import java.util.stream.Collectors;
    
    import org.codelibs.core.beans.util.BeanUtil;
    import org.dbflute.Entity;
    import org.lastaflute.web.response.render.RenderData;
    
    public class RenderDataUtil {
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/ImmutableList.java

       * ImmutableSortedSet.copyOf(elements)}; if you want a {@code List} you can use its {@code
       * asList()} view.
       *
       * <p><b>Java 8+ users:</b> If you want to convert a {@link java.util.stream.Stream} to a sorted
       * {@code ImmutableList}, use {@code stream.sorted().collect(toImmutableList())}.
       *
       * @throws NullPointerException if any element in the input is null
       * @since 21.0
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  7. compat/maven-model/src/test/java/org/apache/maven/model/v4/Xpp3DomPerfTest.java

     * under the License.
     */
    package org.apache.maven.model.v4;
    
    import javax.xml.stream.XMLStreamException;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.nio.file.Paths;
    import java.util.List;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Collectors;
    
    import org.apache.maven.api.model.InputSource;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/FaultTolerantClient.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.crawler.client;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;
    
    import org.codelibs.core.lang.ThreadUtil;
    import org.codelibs.fess.crawler.entity.RequestData;
    import org.codelibs.fess.crawler.entity.ResponseData;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java

                    logger.debug("Interrupting a stream thread.");
                }
                ist.interrupt();
    
                CommonPoolUtil.execute(() -> {
                    try {
                        CloseableUtil.closeQuietly(p.getInputStream());
                    } catch (final Exception e) {
                        logger.warn("Could not close a process input stream.", e);
                    }
                });
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/helper/CrawlingInfoHelper.java

                buf.append(roleTypeList.stream().sorted().collect(Collectors.joining(",")));
            }
    
            @SuppressWarnings("unchecked")
            final List<String> virtualHostList = (List<String>) dataMap.get(fessConfig.getIndexFieldVirtualHost());
            if (virtualHostList != null && !virtualHostList.isEmpty()) {
                buf.append(";v=");
                buf.append(virtualHostList.stream().sorted().collect(Collectors.joining(",")));
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 10.6K bytes
    - Viewed (0)
Back to top