Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 524 for ONCE (0.03 sec)

  1. okhttp/src/main/kotlin/okhttp3/ResponseBody.kt

     * cases the consuming thread must call [close] when it has finished reading the response
     * 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.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/collect/testing/google/SetGenerators.java

          // Work around a GWT compiler bug.  Not explicitly listing this will
          // cause the createArray() method missing in the generated javascript.
          // TODO: Remove this once the GWT bug is fixed.
          implements TestCollectionGenerator<Object> {
        @Override
        public Set<Object> create(Object... elements) {
          return ImmutableSet.copyOf(elements);
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  3. internal/grid/manager.go

    func (m *Manager) IncomingConn(ctx context.Context, conn net.Conn) {
    	remoteAddr := conn.RemoteAddr().String()
    	// will write an OpConnectResponse message to the remote and log it once locally.
    	defer conn.Close()
    	writeErr := func(err error) {
    		if err == nil {
    			return
    		}
    		if errors.Is(err, io.EOF) {
    			return
    		}
    		gridLogOnceIf(ctx, err, remoteAddr)
    		resp := connectResp{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. cmd/erasure-decode.go

    			break
    		}
    
    		var err error
    		bufs, err = reader.Read(bufs)
    		if len(bufs) > 0 {
    			// Set only if there are be enough data for reconstruction.
    			// and only for expected errors, also set once.
    			if errors.Is(err, errFileNotFound) || errors.Is(err, errFileCorrupt) {
    				if derr == nil {
    					derr = err
    				}
    			}
    		} else if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

                return false;
              }
    
              @Override
              public Integer getResult() {
                return seen;
              }
            };
        assertEquals(
            "processLine was called more than once",
            1,
            CharStreams.readLines(r, alwaysFalse).intValue());
    
        // Test a LineProcessor that always returns true.
        r = new StringReader(text);
        LineProcessor<Integer> alwaysTrue =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/cache/Cache.java

       */
      void put(K key, V value);
    
      /**
       * Copies all of the mappings from the specified map to the cache. The effect of this call is
       * equivalent to that of calling {@code put(k, v)} on this map once for each mapping from key
       * {@code k} to value {@code v} in the specified map. The behavior of this operation is undefined
       * if the specified map is modified while the operation is in progress.
       *
       * @since 12.0
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sun Aug 07 02:38:22 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  7. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java

    import java.util.logging.Level;
    import java.util.logging.Logger;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /** Emulation for AbstractFuture in GWT. */
    @SuppressWarnings("nullness") // TODO(b/147136275): Remove once our checker understands & and |.
    @ElementTypesAreNonnullByDefault
    public abstract class AbstractFuture<V extends @Nullable Object> extends InternalFutureFailureAccess
        implements ListenableFuture<V> {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jan 22 19:37:41 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/io/CharStreamsTest.java

                return false;
              }
    
              @Override
              public Integer getResult() {
                return seen;
              }
            };
        assertEquals(
            "processLine was called more than once",
            1,
            CharStreams.readLines(r, alwaysFalse).intValue());
    
        // Test a LineProcessor that always returns true.
        r = new StringReader(text);
        LineProcessor<Integer> alwaysTrue =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  9. docs/bucket/notifications/README.md

    python rabbit.py
    ```
    
    Open another terminal and upload a JPEG image into `images` bucket.
    
    ```
    mc cp myphoto.jpg myminio/images
    ```
    
    You should receive the following event notification via RabbitMQ once the upload completes.
    
    ```py
    python rabbit.py
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  10. src/archive/zip/writer_test.go

    		for j := 0; j < 3; j++ {
    			w, _ := zw.CreateHeader(&FileHeader{
    				Name:   "foo",
    				Method: Deflate,
    			})
    			w.Write(bigBuf)
    		}
    		zw.Close()
    	}
    
    	b.ReportAllocs()
    	// Run once and then reset the timer.
    	// This effectively discards the very large initial flate setup cost,
    	// as well as the initialization of bigBuf.
    	runOnce(&bytes.Buffer{})
    	b.ResetTimer()
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 14.4K bytes
    - Viewed (0)
Back to top