Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for BufferedSink (0.08 sec)

  1. samples/guide/src/main/java/okhttp3/recipes/UploadProgress.java

        public long contentLength() throws IOException {
          return delegate.contentLength();
        }
    
        @Override
        public void writeTo(BufferedSink sink) throws IOException {
          BufferedSink bufferedSink = Okio.buffer(sink(sink));
          delegate.writeTo(bufferedSink);
          bufferedSink.flush();
        }
    
        public Sink sink(Sink sink) {
          return new ForwardingSink(sink) {
            private long totalBytesWritten = 0L;
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 4.2K bytes
    - Viewed (1)
  2. samples/guide/src/main/java/okhttp3/recipes/kt/UploadProgress.kt

                  completed = true
                  progressListener.update(totalBytesWritten, contentLength(), completed)
                }
              }
            }
    
          val bufferedSink = forwardingSink.buffer()
          delegate.writeTo(bufferedSink)
          bufferedSink.flush()
        }
      }
    
      fun interface ProgressListener {
        fun update(
          bytesWritten: Long,
          contentLength: Long,
          done: Boolean,
        )
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt

    import okhttp3.Response
    import okhttp3.mockwebserver.MockResponse
    import okhttp3.mockwebserver.MockWebServer
    import okhttp3.mockwebserver.SocketPolicy
    import okhttp3.testing.PlatformRule
    import okio.Buffer
    import okio.BufferedSink
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.extension.RegisterExtension
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt

    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.coroutines.executeAsync
    import okhttp3.internal.publicsuffix.ResourcePublicSuffixList.Companion.PUBLIC_SUFFIX_RESOURCE
    import okio.BufferedSink
    import okio.ByteString
    import okio.ByteString.Companion.encodeUtf8
    import okio.FileSystem
    import okio.Path
    import okio.Path.Companion.toPath
    import okio.buffer
    
    /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Aug 06 05:33:11 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  5. docs/recipes.md

                return delegate.contentLength();
              }
    
              @Override public void writeTo(BufferedSink sink) throws IOException {
                BufferedSink bufferedSink = Okio.buffer(sink(sink));
                delegate.writeTo(bufferedSink);
                bufferedSink.flush();
              }
    
              public Sink sink(Sink sink) {
                return new ForwardingSink(sink) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 47.8K bytes
    - Viewed (0)
  6. okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt

    import okhttp3.Request
    import okhttp3.RequestBody
    import okhttp3.RequestBody.Companion.toRequestBody
    import okhttp3.logging.HttpLoggingInterceptor.Level
    import okhttp3.testing.PlatformRule
    import okio.Buffer
    import okio.BufferedSink
    import okio.ByteString.Companion.decodeBase64
    import org.junit.jupiter.api.Assertions.fail
    import org.junit.jupiter.api.Assumptions
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Test
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Aug 21 14:27:04 UTC 2025
    - 37.5K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

    import okhttp3.internal.http.StatusLine
    import okhttp3.internal.platform.Platform
    import okhttp3.internal.platform.Platform.Companion.WARN
    import okhttp3.internal.toLongOrDefault
    import okio.Buffer
    import okio.BufferedSink
    import okio.BufferedSource
    import okio.ByteString.Companion.decodeBase64
    import okio.ByteString.Companion.encodeUtf8
    import okio.ByteString.Companion.toByteString
    import okio.FileSystem
    import okio.ForwardingSink
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 26.9K bytes
    - Viewed (0)
  8. okhttp/api/jvm/okhttp.api

    	public final fun encodedValue (I)Ljava/lang/String;
    	public final fun name (I)Ljava/lang/String;
    	public final fun size ()I
    	public final fun value (I)Ljava/lang/String;
    	public fun writeTo (Lokio/BufferedSink;)V
    }
    
    public final class okhttp3/FormBody$Builder {
    	public fun <init> ()V
    	public fun <init> (Ljava/nio/charset/Charset;)V
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 69.4K bytes
    - Viewed (0)
  9. okhttp/api/android/okhttp.api

    	public final fun encodedValue (I)Ljava/lang/String;
    	public final fun name (I)Ljava/lang/String;
    	public final fun size ()I
    	public final fun value (I)Ljava/lang/String;
    	public fun writeTo (Lokio/BufferedSink;)V
    }
    
    public final class okhttp3/FormBody$Builder {
    	public fun <init> ()V
    	public fun <init> (Ljava/nio/charset/Charset;)V
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 69.4K bytes
    - Viewed (0)
Back to top