Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 792 for close1 (0.21 sec)

  1. src/internal/types/testdata/check/builtins0.go

    	clear(m)
    	clear(s)
    	clear([]int{})
    }
    
    func close1() {
    	var c chan int
    	var r <-chan int
    	close() // ERROR "not enough arguments"
    	close(1, 2) // ERROR "too many arguments"
    	close(42 /* ERROR "cannot close non-channel" */)
    	close(r /* ERROR "receive-only channel" */)
    	close(c)
    	_ = close /* ERROR "used as value" */ (c)
    
    	var s []chan int
    	close(s... /* ERROR "invalid use of ..." */ )
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 29.3K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/io/Closer.java

     *
     * <pre>{@code
     * Closer closer = Closer.create();
     * try {
     *   InputStream in = closer.register(openInputStream());
     *   OutputStream out = closer.register(openOutputStream());
     *   // do stuff
     * } catch (Throwable e) {
     *   // ensure that any checked exception types other than IOException that could be thrown are
     *   // provided here, e.g. throw closer.rethrow(e, CheckedException.class);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 15:26:58 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  3. guava/src/com/google/common/io/Closer.java

     *
     * <pre>{@code
     * Closer closer = Closer.create();
     * try {
     *   InputStream in = closer.register(openInputStream());
     *   OutputStream out = closer.register(openOutputStream());
     *   // do stuff
     * } catch (Throwable e) {
     *   // ensure that any checked exception types other than IOException that could be thrown are
     *   // provided here, e.g. throw closer.rethrow(e, CheckedException.class);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 15:26:58 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  4. internal/ioutil/ioutil.go

    		w.wLimit -= int64(n1)
    		return n, err
    	}
    	n1, err = w.Writer.Write(p)
    	w.wLimit -= int64(n1)
    	return n, err
    }
    
    // Close closes the LimitWriter. It behaves like io.Closer.
    func (w *LimitWriter) Close() error {
    	if closer, ok := w.Writer.(io.Closer); ok {
    		return closer.Close()
    	}
    	return nil
    }
    
    // LimitedWriter takes an io.Writer and returns an ioutil.LimitWriter.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/CloserTest.java

        Closer closer = new Closer(suppressor);
    
        TestCloseable c1 = closer.register(TestCloseable.normal());
        TestCloseable c2 = closer.register(TestCloseable.normal());
    
        IOException exception = new IOException();
    
        try {
          try {
            throw exception;
          } catch (Throwable e) {
            throw closer.rethrow(e);
          } finally {
            closer.close();
          }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 15:26:58 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  6. src/net/http/httptest/server.go

    	// wg counts the number of outstanding HTTP requests on this server.
    	// Close blocks until all requests are finished.
    	wg sync.WaitGroup
    
    	mu     sync.Mutex // guards closed and conns
    	closed bool
    	conns  map[net.Conn]http.ConnState // except terminal states
    
    	// client is configured for use with the server.
    	// Its transport is automatically closed when Close is called.
    	client *http.Client
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 10 17:26:10 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        //     we find them, regardless of what the address policies need.
        //
        //  2. EVICTABLE: Connections not required by any address policy. This matches connections that
        //     don't participate in any policy, plus connections whose policies won't be violated if the
        //     connection is closed. We only close these if the idle connection limit is exceeded.
        //
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  8. src/internal/fuzz/worker.go

    // and closes it after the worker process closes the other end.
    func (wc *workerClient) Close() error {
    	wc.mu.Lock()
    	defer wc.mu.Unlock()
    
    	// Close fuzzIn. This signals to the server that there are no more calls,
    	// and it should exit.
    	if err := wc.fuzzIn.Close(); err != nil {
    		wc.fuzzOut.Close()
    		return err
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 26 19:58:28 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  9. cmd/metacache-stream.go

    				continue
    			}
    		}
    	}()
    
    	return objs, nil
    }
    
    // Close and release resources.
    func (w *metacacheWriter) Close() error {
    	if w == nil || w.closer == nil {
    		return nil
    	}
    	w.streamWg.Wait()
    	err := w.closer()
    	w.closer = nil
    	return err
    }
    
    // Reset and start writing to new writer.
    // Close must have been called before this.
    func (w *metacacheWriter) Reset(out io.Writer) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  10. src/net/http/transfer.go

    	mu         sync.Mutex // guards following, and calls to Read and Close
    	sawEOF     bool
    	closed     bool
    	earlyClose bool   // Close called and we didn't read to the end of src
    	onHitEOF   func() // if non-nil, func to call when EOF is Read
    }
    
    // ErrBodyReadAfterClose is returned when reading a [Request] or [Response]
    // Body after the body has been closed. This typically happens when the body is
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 21 22:14:00 UTC 2024
    - 31.1K bytes
    - Viewed (0)
Back to top