Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 867 for Closes (0.15 sec)

  1. src/builtin/builtin.go

    func clear[T ~[]Type | ~map[Type]Type1](t T)
    
    // The close built-in function closes a channel, which must be either
    // bidirectional or send-only. It should be executed only by the sender,
    // never the receiver, and has the effect of shutting down the channel after
    // the last sent value is received. After the last value has been received
    // from a closed channel c, any receive from c will succeed without
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Thu Apr 11 20:22:45 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  2. internal/s3select/select.go

    		}
    	}
    	return rsc.reader.Read(p)
    }
    
    // Close call to implement io.Closer. Calling Read/Seek after Close reopens the
    // object for reading and a subsequent Close call is required to ensure
    // resources are freed.
    func (rsc *ObjectReadSeekCloser) Close() error {
    	rsc.closerOnce.Do(func() {
    		if rsc.reader != nil {
    			rsc.closerErr = rsc.reader.Close()
    			rsc.reader = nil
    		}
    	})
    	return rsc.closerErr
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  3. docs/en/docs/tutorial/request-files.md

        * E.g., `await myfile.seek(0)` would go to the start of the file.
        * This is especially useful if you run `await myfile.read()` once and then need to read the contents again.
    * `close()`: Closes the file.
    
    As all these methods are `async` methods, you need to "await" them.
    
    For example, inside of an `async` *path operation function* you can get the contents with:
    
    ```Python
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Wed Mar 13 19:02:19 GMT 2024
    - 10.2K bytes
    - Viewed (0)
  4. internal/s3select/message.go

    		progressTickerC = progressTicker.C
    	}
    	recordStagingTicker := time.NewTicker(500 * time.Millisecond)
    
    	// Exit conditions:
    	//
    	// 1. If a writer.write() returns false, select loop below exits and
    	// closes `doneCh` to indicate to caller to also exit.
    	//
    	// 2. If caller (Evaluate()) has an error, it sends an error
    	// message and waits for this go-routine to quit in
    	// FinishWithError()
    	//
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 30 15:26:43 GMT 2022
    - 15.2K bytes
    - Viewed (0)
  5. internal/grid/handlers.go

    	// responses from the remote server.
    	// Channel will be closed after error or when remote closes.
    	// responses *must* be read to either an error is returned or the channel is closed.
    	responses *Stream
    	newResp   func() Resp
    
    	// Requests sent to the server.
    	// If the handler is defined with 0 incoming capacity this will be nil.
    	// Channel *must* be closed to signal the end of the stream.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
  6. src/archive/tar/writer.go

    	if err != nil && err != ErrWriteTooLong {
    		tw.err = err
    	}
    	return n, err
    }
    
    // Close closes the tar archive by flushing the padding, and writing the footer.
    // If the current file (from a prior call to [Writer.WriteHeader]) is not fully written,
    // then this returns an error.
    func (tw *Writer) Close() error {
    	if tw.err == ErrWriteAfterClose {
    		return nil
    	}
    	if tw.err != nil {
    		return tw.err
    	}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 19.6K bytes
    - Viewed (0)
  7. src/archive/zip/reader.go

    	dcomp := r.decompressors[method]
    	if dcomp == nil {
    		dcomp = decompressor(method)
    	}
    	return dcomp
    }
    
    // Close closes the Zip file, rendering it unusable for I/O.
    func (rc *ReadCloser) Close() error {
    	return rc.f.Close()
    }
    
    // DataOffset returns the offset of the file's possibly-compressed
    // data, relative to the beginning of the zip file.
    //
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 27.7K bytes
    - Viewed (0)
  8. cmd/admin-heal-ops.go

    		h.currentStatus.Summary = healFinishedStatus
    		h.mutex.Unlock()
    
    		// drain traverse channel so the traversal
    		// go-routine does not leak.
    		go func() {
    			// Eventually the traversal go-routine closes
    			// the channel and returns, so this go-routine
    			// itself will not leak.
    			<-h.traverseAndHealDoneCh
    		}()
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  9. docs/changelogs/changelog_2x.md

     *  Fix: Throw `UnknownServiceException` if a cleartext connection is attempted
        when explicitly forbidden.
     *  Fix: Throw a `SSLPeerUnverifiedException` when host verification fails.
     *  Fix: MockWebServer explicitly closes sockets. (On some Android releases,
        closing the input stream and output stream of a socket is not sufficient.
     *  Fix: Buffer outgoing HTTP/2 frames to limit how many outgoing frames are
        created.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 26.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

        if (compareAndUpdateState(OPEN, WILL_CLOSE)) {
          logger.get().log(FINER, "will close {0}", this);
          future.addListener(
              new Runnable() {
                @Override
                public void run() {
                  checkAndUpdateState(WILL_CLOSE, CLOSING);
                  close();
                  checkAndUpdateState(CLOSING, CLOSED);
                }
              },
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 98.5K bytes
    - Viewed (0)
Back to top