- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 415 for buffered (0.17 sec)
-
internal/deadlineconn/deadlineconn.go
// Package deadlineconn implements net.Conn wrapper with configured deadlines. package deadlineconn import ( "net" "time" ) // DeadlineConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout. type DeadlineConn struct { net.Conn readDeadline time.Duration // sets the read deadline on a connection. writeDeadline time.Duration // sets the write deadline on a connection. }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 2.3K bytes - Viewed (0) -
src/main/java/jcifs/SmbWatchHandle.java
* * Changes in between these calls (as long as the file is open) are buffered by the server, so iteratively calling * this method should provide all changes (size of that buffer can be adjusted through * {@link jcifs.Configuration#getNotifyBufferSize()}). * If the server cannot fulfill the request because the changes did not fit the buffer * it will return an empty list of changes. *
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 2.3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/Stream.kt
val requestBody: BufferedSource val responseBody: BufferedSink /** * Terminate the stream so that no further data is transmitted or received. Note that * [requestBody] may return data after this call; that is the buffered data received before this * stream was canceled. * * This does nothing if [requestBody] and [responseBody] are already closed. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* doesn't include framing overhead. If compression is enabled, uncompressed messages size * is used to calculate this value. It also doesn't include any bytes buffered by the operating * system or network intermediaries. This method returns 0 if no messages are waiting in the * queue. If may return a nonzero value after the web socket has been canceled; this indicates
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
internal/pubsub/pubsub.go
// not atomics: subs []*Sub[T] sync.RWMutex } // Publish message to the subscribers. // Note that publish is always non-blocking send so that we don't block on slow receivers. // Hence receivers should use buffered channel so as not to miss the published events. func (ps *PubSub[T, M]) Publish(item T) { ps.RLock() defer ps.RUnlock() for _, sub := range ps.subs {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CharSink.java
* * @throws IOException if an I/O error occurs while opening the writer */ public abstract Writer openStream() throws IOException; /** * Opens a new buffered {@link Writer} for writing to this sink. The returned stream is not * required to be a {@link BufferedWriter} in order to allow implementations to simply delegate to
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 6.1K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
docs/changelogs/changelog_1x.md
* Fix: Support the `PATCH` method. * Fix: Support request bodies on `DELETE` method. * Fix: Drop the `okhttp-protocols` module. * Internal: Replaced internal byte array buffers with pooled buffers ("OkBuffer"). ## Version 1.3.0 _2014-01-11_ * New: Support for "PATCH" HTTP method in client and MockWebServer. * Fix: Drop `Content-Length` header when redirected from POST to GET.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 6.4K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteSink.java
* * @throws IOException if an I/O error occurs while opening the stream */ public abstract OutputStream openStream() throws IOException; /** * Opens a new buffered {@link OutputStream} for writing to this sink. The returned stream is not * required to be a {@link BufferedOutputStream} in order to allow implementations to simply
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 5.5K bytes - Viewed (0) -
android/guava/src/com/google/common/io/FileBackedOutputStream.java
} } /** * Calls {@link #close} if not already closed, and then resets this object back to its initial * state, for reuse. If data was buffered to a file, it will be deleted. * * @throws IOException if an I/O error occurred while deleting the file buffer */ public synchronized void reset() throws IOException { try { close(); } finally { if (memory == null) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 8.2K bytes - Viewed (0)