- Sort Score
- Num 10 results
- Language All
Results 241 - 250 of 562 for buffers (0.04 seconds)
-
impl/maven-core/src/main/java/org/apache/maven/project/ReactorModelPool.java
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jan 10 07:09:12 GMT 2025 - 2.9K bytes - Click Count (0) -
cmd/background-newdisks-heal-ops_gen_test.go
v := healingTracker{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecodehealingTracker(b *testing.B) { v := healingTracker{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 2.3K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FakeDns.kt
* limitations under the License. */ package okhttp3 import assertk.assertThat import assertk.assertions.containsExactly import java.net.InetAddress import java.net.UnknownHostException import okio.Buffer class FakeDns : Dns { private val hostAddresses: MutableMap<String, List<InetAddress>> = mutableMapOf() private val requestedHosts: MutableList<String> = mutableListOf()Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 2.5K bytes - Click Count (0) -
docs/ru/docs/async.md
<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: Tue Sep 30 11:24:39 GMT 2025 - 38.5K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Hpack.kt
import okhttp3.internal.http2.Header.Companion.TARGET_PATH import okhttp3.internal.http2.Header.Companion.TARGET_SCHEME import okhttp3.internal.unmodifiable import okio.Buffer import okio.BufferedSource import okio.ByteString import okio.Source import okio.buffer /** * Read and write HPACK v10. * * http://tools.ietf.org/html/draft-ietf-httpbis-header-compression-12 *
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Mon May 05 16:01:00 GMT 2025 - 22.4K bytes - Click Count (0) -
compat/maven-settings-builder/src/main/java/org/apache/maven/settings/building/SettingsBuildingException.java
public List<SettingsProblem> getProblems() { return problems; } private static String toMessage(List<SettingsProblem> problems) { StringWriter buffer = new StringWriter(1024); PrintWriter writer = new PrintWriter(buffer); writer.print(problems.size()); writer.print((problems.size() == 1) ? " problem was " : " problems were ");
Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 2.9K bytes - Click Count (0) -
cmd/bootstrap-peer-server_gen_test.go
v := ServerSystemConfig{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecodeServerSystemConfig(b *testing.B) { v := ServerSystemConfig{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 2.4K bytes - Click Count (0) -
cmd/bucket-metadata_gen_test.go
v := BucketMetadata{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecodeBucketMetadata(b *testing.B) { v := BucketMetadata{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 2.3K bytes - Click Count (0) -
src/bytes/example_test.go
"fmt" "io" "os" "slices" "strconv" "unicode" ) func ExampleBuffer() { var b bytes.Buffer // A Buffer needs no initialization. b.Write([]byte("Hello ")) fmt.Fprintf(&b, "world!") b.WriteTo(os.Stdout) // Output: Hello world! } func ExampleBuffer_reader() { // A Buffer can turn a string or a []byte into an io.Reader. buf := bytes.NewBufferString("R29waGVycyBydWxlIQ==")
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon May 12 16:07:54 GMT 2025 - 16.5K bytes - Click Count (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt
@Test fun responseBodyIsBinary() { setLevel(Level.BODY) val buffer = Buffer() buffer.writeUtf8CodePoint(0x89) buffer.writeUtf8CodePoint(0x50) buffer.writeUtf8CodePoint(0x4e) buffer.writeUtf8CodePoint(0x47) buffer.writeUtf8CodePoint(0x0d) buffer.writeUtf8CodePoint(0x0a) buffer.writeUtf8CodePoint(0x1a) buffer.writeUtf8CodePoint(0x0a) server.enqueue( MockResponse
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Nov 07 02:57:33 GMT 2025 - 39.4K bytes - Click Count (0)