- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 74 for WriteTo (0.2 sec)
-
okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt
setLevel(Level.HEADERS) server.enqueue(MockResponse()) val body: RequestBody = object : RequestBody() { override fun contentType() = PLAIN override fun writeTo(sink: BufferedSink) { sink.writeUtf8("Hi!") } } val response = client.newCall(request().post(body).build()).execute() response.body.close() applicationLogs
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 37.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/ThreadOutputMuxer.java
} catch (InterruptedException e) { throw new RuntimeException(e); } try { projectOs.writeTo(originalSystemOUtStream); } catch (IOException e) { throw new RuntimeException(e); } projectOs.reset();
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Wed Sep 06 08:39:32 GMT 2023 - 12.8K bytes - Viewed (0) -
internal/http/server.go
return nil } // Write all running goroutines. tmp, err := os.CreateTemp("", "minio-goroutines-*.txt") if err == nil { _ = pprof.Lookup("goroutine").WriteTo(tmp, 1) tmp.Close() return errors.New("timed out. some connections are still active. goroutines written to " + tmp.Name()) } return errors.New("timed out. some connections are still active")
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
return object : RequestBody() { override fun contentType(): MediaType? { return "text/plain".toMediaTypeOrNull() } @Throws(IOException::class) override fun writeTo(sink: BufferedSink) { try { sink.writeUtf8("abc") sink.flush() Thread.sleep(sleepMillis.toLong()) sink.writeUtf8("def") } catch (e: InterruptedException) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
src/archive/tar/reader_test.go
} case testWriteTo: f := &testFile{ops: tf.ops} got, err := fr.WriteTo(f) if _, ok := err.(testError); ok { t.Errorf("test %d.%d, WriteTo(): %v", i, j, err) } else if got != tf.wantCnt || err != tf.wantErr { t.Errorf("test %d.%d, WriteTo() = (%d, %v), want (%d, %v)", i, j, got, err, tf.wantCnt, tf.wantErr) } if len(f.ops) > 0 {
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Mon Nov 21 21:14:38 GMT 2022 - 47.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/InterceptorTest.kt
} override fun contentLength(): Long { return original!!.contentLength() } override fun writeTo(sink: BufferedSink) { val uppercase = uppercase(sink) val bufferedSink = uppercase.buffer() original!!.writeTo(bufferedSink) bufferedSink.emit() } } } private fun uppercase(original: BufferedSink): Sink {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 27.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
override fun contentType(): MediaType? { return "text/plain".toMediaType() } override fun contentLength(): Long { return chunk!!.size * 8L } override fun writeTo(sink: BufferedSink) { try { var i = 0 while (i < contentLength()) { sink.write(chunk!!) sink.flush() Thread.sleep(100) i += chunk.size
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 56.9K bytes - Viewed (0) -
android/guava/src/com/google/common/math/Stats.java
* versions. */ public byte[] toByteArray() { ByteBuffer buff = ByteBuffer.allocate(BYTES).order(ByteOrder.LITTLE_ENDIAN); writeTo(buff); return buff.array(); } /** * Writes to the given {@link ByteBuffer} a byte representation of this instance. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 22K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/MultipartReaderTest.kt
.addFormDataPart("color", "Brown") .addFormDataPart("animal", "fox.txt", "Fox".toRequestBody()) .build() val bodyContent = Buffer() body.writeTo(bodyContent) val reader = MultipartReader(bodyContent, "boundary") val quickPart = reader.nextPart()!! assertThat(quickPart.headers).isEqualTo( headersOf( "Content-Type",
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/BloomFilterTest.java
BloomFilter<byte[]> bf = BloomFilter.create(funnel, 100); for (int i = 0; i < 100; i++) { bf.put(Ints.toByteArray(i)); } ByteArrayOutputStream out = new ByteArrayOutputStream(); bf.writeTo(out); BloomFilter<byte[]> read = BloomFilter.readFrom(new ByteArrayInputStream(out.toByteArray()), funnel); assertThat(read).isEqualTo(bf); assertThat(read.expectedFpp()).isGreaterThan(0); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Nov 09 22:49:56 GMT 2023 - 21.3K bytes - Viewed (0)