- Sort Score
- Num 10 results
- Language All
Results 481 - 490 of 1,033 for Close (0.02 seconds)
-
internal/logger/target/kafka/kafka.go
h.storeCtxCancel() } // Set logch to nil and close it. // This will block all Send operations, // and finish the existing ones. // All future ones will be discarded. h.logChMu.Lock() xioutil.SafeClose(h.logCh) h.logCh = nil h.logChMu.Unlock() if h.producer != nil { h.producer.Close() h.client.Close() } // Wait for messages to be sent... h.wg.Wait() }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/vagrant/VagrantMachine.java
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 7.5K bytes - Click Count (0) -
misc/go_android_exec/main.go
args += "; echo -n " + exitStr + "$?" cmd := adbCmd("exec-out", args) cmd.Stdout = filter // If the adb subprocess somehow hangs, go test will kill this wrapper // and wait for our os.Stderr (and os.Stdout) to close as a result. // However, if the os.Stderr (or os.Stdout) file descriptors are // passed on, the hanging adb subprocess will hold them open and // go test will hang forever. //
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K bytes - Click Count (0) -
docs/changelogs/changelog_4x.md
the certificate that follows and the last certificate is signed by a trusted root. * Fix: Don't lose HTTP/2 flow control bytes when incoming data races with a stream close. If this happened enough then eventually the connection would stall. * Fix: Acknowledge and apply inbound HTTP/2 settings atomically. Previously we had a race where we
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Click Count (0) -
android/guava/src/com/google/common/hash/Funnels.java
* funnel} an object to a {@code PrimitiveSink} if there is already a way to write the contents of * the object to an {@code OutputStream}. * * <p>The {@code close} and {@code flush} methods of the returned {@code OutputStream} do nothing, * and no method throws {@code IOException}. * * @since 13.0 */ public static OutputStream asOutputStream(PrimitiveSink sink) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 7.2K bytes - Click Count (0) -
src/main/webapp/js/admin/adminlte.min.js.map
is._config.title))\n }\n\n if (this._config.subtitle != null) {\n toastHeader.append($('<small />').html(this._config.subtitle))\n }\n\n if (this._config.close == true) {\n const toastClose = $('<button data-dismiss=\"toast\" />').attr('type', 'button').addClass('ml-2 mb-1 close').attr('aria-label', 'Close').append('<span aria-hidden=\"true\">×</span>')\n\n if (this._config.title == null) {\n toastClose.toggleClass('ml-2 ml-auto')\n }\n\n toastHe...
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Oct 26 01:49:09 GMT 2024 - 132.4K bytes - Click Count (0) -
.github/DISCUSSION_TEMPLATE/questions.yml
And there's a high chance that you will find the solution along the way and you won't even have to submit it and wait for an answer. 😎 As there are too many questions, I'll have to discard and close the incomplete ones. That will allow me (and others) to focus on helping people like you that follow the whole process and help us help you. 🤓 - type: checkboxes id: checks attributes: label: First CheckCreated: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Aug 03 15:59:41 GMT 2023 - 5.8K bytes - Click Count (0) -
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)
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Feb 17 20:31:46 GMT 2023 - 18K bytes - Click Count (0) -
cmd/streaming-v4-unsigned.go
type s3UnsignedChunkedReader struct { reader *bufio.Reader trailers http.Header buffer []byte offset int err error debug bool } func (cr *s3UnsignedChunkedReader) Close() (err error) { return cr.err } // Read - implements `io.Reader`, which transparently decodes // the incoming AWS Signature V4 streaming signature. func (cr *s3UnsignedChunkedReader) Read(buf []byte) (n int, err error) {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Apr 03 14:55:52 GMT 2025 - 6.3K bytes - Click Count (0) -
src/main/java/jcifs/http/NetworkExplorer.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 23.4K bytes - Click Count (0)