Search Options

Results per page
Sort
Preferred Languages
Advance

Results 701 - 710 of 1,168 for lose (0.04 sec)

  1. cmd/post-policy_test.go

    	}
    	// Set the File formData
    	writer, err := w.CreateFormFile("file", "upload.txt")
    	if err != nil {
    		// return nil, err
    		return nil, err
    	}
    	writer.Write([]byte("hello world"))
    	// Close before creating the new request.
    	w.Close()
    
    	// Set the body equal to the created policy.
    	reader := bytes.NewReader(buf.Bytes())
    
    	req, err := http.NewRequest(http.MethodPost, makeTestTargetURL(endPoint, bucketName, "", nil), reader)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

      private val routeB1 = factory.newRoute(addressB)
      private val addressC = factory.newAddress("c")
      private val routeC1 = factory.newRoute(addressC)
    
      @AfterEach fun tearDown() {
        factory.close()
        peer.close()
      }
    
      @Test fun connectionsEvictedWhenIdleLongEnough() {
        val pool = factory.newConnectionPool()
        val c1 = factory.newConnection(pool, routeA1, 50L)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  3. api/go1.17.txt

    pkg archive/zip, method (*Writer) CreateRaw(*FileHeader) (io.Writer, error)
    pkg compress/lzw, method (*Reader) Close() error
    pkg compress/lzw, method (*Reader) Read([]uint8) (int, error)
    pkg compress/lzw, method (*Reader) Reset(io.Reader, Order, int)
    pkg compress/lzw, method (*Writer) Close() error
    pkg compress/lzw, method (*Writer) Reset(io.Writer, Order, int)
    pkg compress/lzw, method (*Writer) Write([]uint8) (int, error)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Feb 17 20:31:46 UTC 2023
    - 18K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/testing/ClusterException.java

    import java.util.Arrays;
    import java.util.Collection;
    import java.util.Collections;
    
    /**
     * An {@link ClusterException} is a data structure that allows for some code to "throw multiple
     * exceptions", or something close to it. The prototypical code that calls for this class is
     * presented below:
     *
     * <pre>
     * void runManyThings({@literal List<ThingToRun>} thingsToRun) {
     *   for (ThingToRun thingToRun : thingsToRun) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 26 20:07:17 UTC 2023
    - 4K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/SmbComWriteAndX.java

                                Config.getInt( "jcifs.smb1.smb.client.WriteAndX.ReadAndX", 1 );
        private static final int CLOSE_BATCH_LIMIT =
                                Config.getInt( "jcifs.smb1.smb.client.WriteAndX.Close", 1 );
    
        private int fid,
            remaining,
            dataLength,
            dataOffset,
            off;
        private byte[] b;
        private long offset;
    
    private int pad;
    
        int writeMode;
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 4.3K bytes
    - Viewed (0)
  6. compat/maven-embedder/src/test/java/org/apache/maven/cli/transfer/SimplexTransferListenerTest.java

                    new TransferResource(null, null, "http://maven.org/test/test-resource", new File("file"), null);
            DefaultRepositorySystemSession session = new DefaultRepositorySystemSession(h -> false); // no close handle
    
            // for technical reasons we cannot throw here, even if delegate does cancel transfer
            listener.transferInitiated(event(session, resource, TransferEvent.EventType.INITIATED));
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  7. cmd/namespace-lock_test.go

    		// lk1; ref=1
    		if !nsLk.lock(ctx, "volume", "path", "source", "opsID", false, time.Second) {
    			t.Fatal("failed to acquire lock")
    		}
    
    		// lk2
    		lk2ch := make(chan struct{})
    		go func() {
    			defer close(lk2ch)
    			nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 1*time.Millisecond)
    		}()
    		time.Sleep(1 * time.Millisecond) // wait for goroutine to advance; ref=2
    
    		// Unlock the 1st lock; ref=1 after this line
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 3.1K bytes
    - Viewed (0)
  8. okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt

                override fun contentType() = null
    
                override fun contentLength() = -1L
    
                override fun source() =
                  object : ForwardingSource(Buffer()) {
                    override fun close() {
                      responseClosed = true
                    }
                  }.buffer()
              },
            )
            .build()
    
        var responseClosed = false
        var canceled = false
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:24:38 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ForwardingList.java

    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public abstract class ForwardingList<E extends @Nullable Object> extends ForwardingCollection<E>
        implements List<E> {
      // TODO(lowasser): identify places where thread safety is actually lost
    
      /** Constructor for use by subclasses. */
      protected ForwardingList() {}
    
      @Override
      protected abstract List<E> delegate();
    
      @Override
      public void add(int index, @ParametricNullness E element) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 15:26:39 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/io/ByteSourceTest.java

        assertTrue(source.wasStreamOpened());
        assertFalse(source.wasStreamClosed());
    
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        ByteStreams.copy(in, out);
        in.close();
        out.close();
    
        assertTrue(source.wasStreamClosed());
        assertArrayEquals(bytes, out.toByteArray());
      }
    
      public void testSize() throws IOException {
        assertEquals(bytes.length, source.size());
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 15.4K bytes
    - Viewed (0)
Back to top