- Sort Score
- Num 10 results
- Language All
Results 301 - 310 of 551 for buffers (0.04 seconds)
-
docs/de/docs/async.md
<img src="/img/async/concurrent-burgers/concurrent-burgers-02.png" class="illustration"> Der Kassierer sagt etwas zum Koch in der Küche, damit dieser weiß, dass er Ihre Burger zubereiten muss (obwohl er gerade die für die vorherigen Kunden zubereitet). <img src="/img/async/concurrent-burgers/concurrent-burgers-03.png" class="illustration"> Sie bezahlen. 💸 Der Kassierer gibt Ihnen die Nummer Ihrer Bestellung.
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Sep 20 15:10:09 GMT 2025 - 27.9K bytes - Click Count (0) -
okcurl/src/main/kotlin/okhttp3/curl/internal/-MainCommon.kt
// Stream the response to the System.out as it is returned from the server. val out = System.out.sink() val source = response.body.source() while (!source.exhausted()) { out.write(source.buffer, source.buffer.size) out.flush() } response.body.close() } catch (e: IOException) { e.printStackTrace() } finally { close() }Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 2.7K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt
import okio.FileNotFoundException import okio.FileSystem import okio.ForwardingFileSystem import okio.ForwardingSource import okio.Path import okio.Sink import okio.Source import okio.blackholeSink import okio.buffer /** * A cache that uses a bounded amount of space on a filesystem. Each cache entry has a string key * and a fixed number of values. Each key must match the regex `[a-z0-9_-]{1,64}`. Values are byteCreated: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 34.7K bytes - Click Count (0) -
cmd/consolelogger.go
types "github.com/minio/minio/internal/logger/target/loggertypes" "github.com/minio/minio/internal/pubsub" xnet "github.com/minio/pkg/v3/net" ) // number of log messages to buffer const defaultLogBufferCount = 10000 // HTTPConsoleLoggerSys holds global console logger state type HTTPConsoleLoggerSys struct { totalMessages int64 failedMessages int64 sync.RWMutex
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.4K bytes - Click Count (0) -
cmd/erasure-decode_test.go
writeAlgorithm = DefaultBitrotAlgorithm } buffer := make([]byte, test.blocksize, 2*test.blocksize) writers := make([]io.Writer, len(disks)) for i, disk := range disks { writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(test.data), writeAlgorithm, erasure.ShardSize()) } n, err := erasure.Encode(t.Context(), bytes.NewReader(data), writers, buffer, erasure.dataBlocks+1) closeBitrotWriters(writers)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 21K bytes - Click Count (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
import mockwebserver3.SocketEffect import mockwebserver3.SocketEffect.CloseSocket import mockwebserver3.SocketEffect.CloseStream import mockwebserver3.SocketEffect.ShutdownConnection import okio.Buffer import okio.ByteString internal fun Dispatcher.wrap(): mockwebserver3.Dispatcher { if (this is QueueDispatcher) return this.delegate val delegate = this return object : mockwebserver3.Dispatcher() {
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 03 13:16:34 GMT 2025 - 4.1K bytes - Click Count (1) -
tensorflow/c/c_api.h
// serialized representation of a `RunOptions` protocol buffer. // - `run_metadata` may be NULL, in which case it will be ignored; or // non-NULL, in which case it must point to an empty, freshly allocated // `TF_Buffer` that may be updated to contain the serialized representation // of a `RunMetadata` protocol buffer. // // The caller retains ownership of `input_values` (which can be deleted using
Created: Tue Dec 30 12:39:10 GMT 2025 - Last Modified: Thu Oct 26 21:08:15 GMT 2023 - 82.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt
import java.io.IOException import java.io.InterruptedIOException import java.util.concurrent.CountDownLatch import java.util.concurrent.atomic.AtomicBoolean import okio.ByteString import okio.Source import okio.buffer internal abstract class BasePublicSuffixList : PublicSuffixList { /** True after we've attempted to read the list for the first time. */ private val listRead = AtomicBoolean(false)Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon Jul 28 07:33:49 GMT 2025 - 3.6K bytes - Click Count (0) -
okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/MappingTables.kt
import kotlin.streams.toList import okio.Buffer /** Index [table] for compactness as specified by `IdnaMappingTable`. */ fun buildIdnaMappingTableData(table: SimpleIdnaMappingTable): IdnaMappingTableData { val simplified = mergeAdjacentRanges(table.mappings) val withoutSectionSpans = withoutSectionSpans(simplified) val sections = sections(withoutSectionSpans) val rangesBuffer = Buffer() val mappingsBuffer = StringBuilder()
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 8.3K bytes - Click Count (0) -
docs/zh-hant/docs/async.md
你和你的戀人去速食店,排隊等候時,收銀員正在幫排在你前面的人點餐。😍 <img src="/img/async/concurrent-burgers/concurrent-burgers-01.png" class="illustration"> 輪到你了,你給你與你的戀人點了兩個豪華漢堡。🍔🍔 <img src="/img/async/concurrent-burgers/concurrent-burgers-02.png" class="illustration"> 收銀員通知廚房準備你的漢堡(儘管他們還在為前面其他顧客準備食物)。 <img src="/img/async/concurrent-burgers/concurrent-burgers-03.png" class="illustration"> 之後你完成付款。💸 收銀員給你一個號碼牌。
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sun Aug 31 09:56:21 GMT 2025 - 21.1K bytes - Click Count (0)