Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 849 for upstream (0.07 sec)

  1. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

                        } else {
                            ignoreFields = new String[] { Constants.INDEXING_TARGET, Constants.SESSION_ID };
                        }
                        stream(ignoreFields).of(stream -> stream.map(String::trim).forEach(s -> dataMap.remove(s)));
    
                        indexUpdateCallback.store(paramMap, dataMap);
                        crawlerStatsHelper.record(keyObj, StatsAction.PROCESSED);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  2. internal/grid/README.md

        conn := manager.Connection(host).Subroute("asubroute")
    	
        payload := []byte("request")
        stream, err := conn.NewStream(ctx, grid.HandlerDiskInfo, payload)
    	if err != nil {
            return err
        }
        // Read results from the stream
        err = stream.Results(func(result []byte) error {
            fmt.Println("Got result", string(result))
    
            // Return the response for reuse
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/Multimaps.java

        private void writeObject(ObjectOutputStream stream) throws IOException {
          stream.defaultWriteObject();
          stream.writeObject(factory);
          stream.writeObject(backingMap());
        }
    
        @GwtIncompatible // java.io.ObjectInputStream
        @J2ktIncompatible
        @SuppressWarnings("unchecked") // reading data stored by writeObject
        private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 86.3K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/Connection.kt

     * Attempting to create new streams on these allocations will fail.
     *
     * Note that an allocation may be released before its stream is completed. This is intended to make
     * bookkeeping easier for the caller: releasing the allocation as soon as the terminal stream has
     * been found. But only complete the stream once its data stream has been exhausted.
     */
    interface Connection {
      /** Returns the route used by this connection. */
      fun route(): Route
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/ResponseBody.kt

     * body.
     *
     * ### The response body can be consumed only once.
     *
     * This class may be used to stream very large responses. For example, it is possible to use this
     * class to read a response that is larger than the entire memory allocated to the current process.
     * It can even stream a response larger than the total storage on the current device, which is a
     * common requirement for video streaming applications.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  6. src/main/java/jcifs/http/Handler.java

        private CIFSContext transportContext;
    
    
        /**
         * Sets the URL stream handler factory for the environment. This
         * allows specification of the factory used in creating underlying
         * stream handlers. This can be called once per JVM instance.
         *
         * @param factory
         *            The URL stream handler factory.
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 6.9K bytes
    - Viewed (0)
  7. compat/maven-model-builder/src/main/java/org/apache/maven/model/io/DefaultModelReader.java

     */
    package org.apache.maven.model.io;
    
    import javax.inject.Inject;
    import javax.inject.Named;
    import javax.inject.Singleton;
    import javax.xml.stream.Location;
    import javax.xml.stream.XMLInputFactory;
    import javax.xml.stream.XMLStreamException;
    import javax.xml.stream.XMLStreamReader;
    
    import java.io.File;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.Reader;
    import java.nio.file.Files;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

                try {
                    ist.interrupt();
                } catch (final Exception e) {
                    logger.warn("Could not interrupt a thread of an input stream.", e);
                }
    
                final CountDownLatch latch = new CountDownLatch(3);
                final Process process = jobProcess.getProcess();
                new Thread(() -> {
                    try {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  9. cmd/testdata/undeleteable-object.tgz

    Kƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ‰ Z•`=A#µß ñN`áÚ¦EcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistœ ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘ ªPartASizes‘ ¤Size ¥MTimeÓ É ¸í80§MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¬content-type¸application/octet-stream¤etagÙ 08ba8b8411960c5bc1e2¡v ΰ\ Ë ¤nullÄ%O‹óãB !EÆÐ ÃóÑÑä´.5t Ã*uºÅ{ _dùrd=EC multisitea/data/disterasure/xl3/.minio.sys/config/iam/format.json/xl.meta XL2 Æ o Ä$•Ä Ó ÉŸþ¦ ÆHÄ ¼… Å Cƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ ÷ ·_ñ7MùtyÑ ÿ? ¦EcAlgo £EcM £EcN §EcBSizeÒ...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 26 00:31:12 UTC 2024
    - 8.7M bytes
    - Viewed (0)
  10. compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelWriter.java

         */
        void write(Writer output, Map<String, Object> options, Model model) throws IOException;
    
        /**
         * Writes the supplied model to the specified byte stream. The stream will be automatically closed before the method
         * returns.
         *
         * @param output The stream to serialize the model 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
    - 4.7K bytes
    - Viewed (0)
Back to top