Search Options

Results per page
Sort
Preferred Languages
Advance

Results 611 - 620 of 737 for iostream (0.06 sec)

  1. cmd/erasure-sets.go

    			return srcSet.CopyObject(ctx, srcBucket, srcObject, dstBucket, dstObject, srcInfo, srcOpts, dstOpts)
    		}
    		// Destination is not versioned and source version ID is empty
    		// perform an in-place update.
    		if !dstOpts.Versioned && srcOpts.VersionID == "" {
    			srcInfo.Reader.Close() // We are not interested in the reader stream at this point close it.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  2. docs/features/https.md

              for ((name, value) in response.headers) {
                println("$name: $value")
              }
    
              println(response.body!!.string())
            }
          }
    
          /**
           * Returns an input stream containing one or more certificate PEM files. This implementation just
           * embeds the PEM files in Java strings; most applications will instead read this from a resource
           * file that gets bundled with the application.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Dec 24 00:16:30 UTC 2022
    - 10.5K bytes
    - Viewed (0)
  3. internal/s3select/csv/reader.go

    	bufferPool   sync.Pool        // pool of []byte objects for input
    	csvDstPool   sync.Pool        // pool of [][]string used for output
    	close        chan struct{}    // used for shutting down the splitter before end of stream
    	readerWg     sync.WaitGroup   // used to keep track of async reader.
    }
    
    // queueItem is an item in the queue.
    type queueItem struct {
    	input []byte          // raw input sent to the worker
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/ConnectionReuseTest.kt

        assertThat(server.takeRequest().sequenceNumber).isEqualTo(0)
      }
    
      /**
       * Regression test for an edge case where closing response body in the HTTP engine doesn't release
       * the corresponding stream allocation. This test keeps those response bodies alive and reads
       * them after the redirect has completed. This forces a connection to not be reused where it would
       * be otherwise.
       *
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  5. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/BaseParser.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.cling.invoker;
    
    import javax.xml.stream.XMLStreamException;
    
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.PrintWriter;
    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.nio.file.Paths;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  6. impl/maven-core/src/main/java/org/apache/maven/execution/MavenExecutionRequest.java

        // ----------------------------------------------------------------------
        // Reactor Make Mode
        // ----------------------------------------------------------------------
    
        String REACTOR_MAKE_UPSTREAM = "make-upstream";
    
        String REACTOR_MAKE_DOWNSTREAM = "make-downstream";
    
        String REACTOR_MAKE_BOTH = "make-both";
    
        // ----------------------------------------------------------------------
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  7. mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

        ) = apply {
          headersDelayNanos = unit.toNanos(delay)
        }
    
        /**
         * When [protocols][MockWebServer.protocols] include [HTTP_2][okhttp3.Protocol], this attaches a
         * pushed stream to this response.
         */
        fun addPush(promise: PushPromise) =
          apply {
            this.pushPromises += promise
          }
    
        /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. fastapi/applications.py

                Type[Response],
                Doc(
                    """
                    The default response class to be used.
    
                    Read more in the
                    [FastAPI docs for Custom Response - HTML, Stream, File, others](https://fastapi.tiangolo.com/advanced/custom-response/#default-response-class).
    
                    **Example**
    
                    ```python
                    from fastapi import FastAPI
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Aug 17 04:52:31 UTC 2024
    - 172.2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/suggest/index/contents/DefaultContentsParser.java

            }
            if (value instanceof String[]) {
                return (String[]) value;
            }
            if (value instanceof List) {
                return ((List<?>) value).stream().map(Object::toString).toArray(n -> new String[n]);
            }
            if (value != null) {
                return new String[] { value.toString() };
            }
    
            return new String[0];
        }
    
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:54 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  10. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableList.java

    import java.util.Arrays;
    import java.util.Collection;
    import java.util.Collections;
    import java.util.Comparator;
    import java.util.Iterator;
    import java.util.List;
    import java.util.RandomAccess;
    import java.util.stream.Collector;
    import jsinterop.annotations.JsMethod;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * GWT emulated version of {@link com.google.common.collect.ImmutableList}. TODO(cpovirk): more doc
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 22:14:46 UTC 2024
    - 11.1K bytes
    - Viewed (0)
Back to top