- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 282 for sing (0.04 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
/** * Returns a sink that can be used to write data to the peer. * * @throws IllegalStateException if this stream was initiated by the peer and a [writeHeaders] has * not yet been sent. */ fun getSink(): Sink { this.withLock { check(hasResponseHeaders || isLocallyInitiated) { "reply before requesting the sink" } } return sink }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 23.2K bytes - Viewed (0) -
internal/s3select/jstream/decoder_test.go
var ( counter int mv *MetaValue body = `{ "bio": "bada bing bada boom", "id": 1, "name": "Charles" } { "bio": "bada bing bada boom", "id": 2, "name": "Charles" } { "bio": "bada bing bada boom", "id": 3, "name": "Charles" } { "bio": "bada bing bada boom", "id": 4, "name": "Charles" } { "bio": "bada bing bada boom", "id": 5, "name": "Charles" } ` ) decoder := NewDecoder(mkReader(body), 0)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 6.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/FileOperatorTest.kt
randomAccessFile!!.getChannel().force(false) val source = file!!.source().buffer() return source.readByteString() } private fun write(data: ByteString) { val sink = file!!.sink().buffer() sink.write(data) sink.close() }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallKotlinTest.kt
} override fun writeTo(sink: BufferedSink) { sink.writeUtf8("<el") sink.flush() throw IOException("failed to stream the XML") } } class ValidRequestBody : RequestBody() { override fun contentType(): MediaType { return "application/xml".toMediaType() } override fun writeTo(sink: BufferedSink) { sink.writeUtf8("<element/>")
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 8.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-RequestBodyCommon.kt
return object : RequestBody() { override fun contentType() = contentType override fun contentLength() = byteCount.toLong() override fun writeTo(sink: BufferedSink) { sink.write(this@commonToRequestBody, offset, byteCount) } } } @Suppress("unused") fun RequestBody.commonContentLength(): Long = -1L @Suppress("unused")
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.7K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PostStreaming.java
@Override public MediaType contentType() { return MEDIA_TYPE_MARKDOWN; } @Override public void writeTo(BufferedSink sink) throws IOException { sink.writeUtf8("Numbers\n"); sink.writeUtf8("-------\n"); for (int i = 2; i <= 997; i++) { sink.writeUtf8(String.format(" * %s = %s\n", i, factor(i))); } } private String factor(int n) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Fri Jul 06 03:18:15 UTC 2018 - 2.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
val source = this.source!! val sink = this.sink!! val tunnelCodec = Http1ExchangeCodec( // No client for CONNECT tunnels: client = null, carrier = this, source = source, sink = sink, ) source.timeout().timeout(readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 18.6K bytes - Viewed (0) -
common-protos/k8s.io/apimachinery/pkg/api/resource/generated.proto
// // <digit> ::= 0 | 1 | ... | 9 // <digits> ::= <digit> | <digit><digits> // <number> ::= <digits> | <digits>.<digits> | <digits>. | .<digits> // <sign> ::= "+" | "-" // <signedNumber> ::= <number> | <sign><number> // <suffix> ::= <binarySI> | <decimalExponent> | <decimalSI> // <binarySI> ::= Ki | Mi | Gi | Ti | Pi | Ei //
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 3.9K bytes - Viewed (0) -
src/main/java/org/codelibs/core/convert/StringConversionUtil.java
/** MINUS SIGN */ public static final char MINUS_SIGN = '\u2212'; /** FULLWIDTH HYPHEN-MINUS */ public static final char FULLWIDTH_HYPHEN_MINUS = '\uFF0D'; /** CENT SIGN */ public static final char CENT_SIGN = '\u00A2'; /** FULLWIDTH CENT SIGN */ public static final char FULLWIDTH_CENT_SIGN = '\uFFE0'; /** POUND SIGN */
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 6.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CharSourceTest.java
TestCharSink sink = new TestCharSink(); assertFalse(sink.wasStreamOpened() || sink.wasStreamClosed()); assertEquals(STRING.length(), source.copyTo(sink)); assertTrue(source.wasStreamOpened() && source.wasStreamClosed()); assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed()); assertEquals(STRING, sink.getString()); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 07 15:26:58 UTC 2024 - 11.4K bytes - Viewed (0)