Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 52 for BufferedSink (0.21 sec)

  1. okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt

    import okhttp3.Headers.Companion.headersOf
    import okhttp3.internal.duplex.AsyncRequestBody
    import okhttp3.internal.http2.ErrorCode
    import okhttp3.testing.PlatformRule
    import okio.BufferedSink
    import okio.IOException
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Disabled
    import org.junit.jupiter.api.Tag
    import org.junit.jupiter.api.Test
    import org.junit.jupiter.api.Timeout
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.idn
    
    import java.io.IOException
    import okio.Buffer
    import okio.BufferedSink
    import okio.BufferedSource
    import okio.ByteString
    import okio.ByteString.Companion.encodeUtf8
    import okio.Options
    
    /**
     * A decoded [mapping table] that can perform the [mapping step] of IDNA processing.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/DuplexTest.kt

    import okhttp3.TestUtil.assumeNotWindows
    import okhttp3.internal.RecordingOkAuthenticator
    import okhttp3.internal.duplex.AsyncRequestBody
    import okhttp3.testing.PlatformRule
    import okio.BufferedSink
    import org.junit.jupiter.api.AfterEach
    import org.junit.jupiter.api.Assertions.assertTrue
    import org.junit.jupiter.api.BeforeEach
    import org.junit.jupiter.api.Disabled
    import org.junit.jupiter.api.Tag
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt

    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.coroutines.executeAsync
    import okhttp3.internal.publicsuffix.PublicSuffixDatabase.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
    import okio.gzip
    
    /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:24:38 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

    import okio.Buffer
    import okio.BufferedSink
    import okio.ByteString
    
    /**
     * An [RFC 6455][rfc_6455]-compatible WebSocket frame writer.
     *
     * This class is not thread safe.
     *
     * [rfc_6455]: http://tools.ietf.org/html/rfc6455
     */
    class WebSocketWriter(
      private val isClient: Boolean,
      val sink: BufferedSink,
      val random: Random,
      private val perMessageDeflate: Boolean,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/MultipartBody.kt

     */
    package okhttp3
    
    import java.io.IOException
    import java.util.UUID
    import okhttp3.MediaType.Companion.toMediaType
    import okhttp3.internal.toImmutableList
    import okio.Buffer
    import okio.BufferedSink
    import okio.ByteString
    import okio.ByteString.Companion.encodeUtf8
    
    /**
     * An [RFC 2387][rfc_2387]-compliant request body.
     *
     * [rfc_2387]: http://www.ietf.org/rfc/rfc2387.txt
     */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

    import okhttp3.internal.http.StatusLine
    import okhttp3.internal.http.promisesBody
    import okhttp3.internal.http.receiveHeaders
    import okhttp3.internal.skipAll
    import okio.Buffer
    import okio.BufferedSink
    import okio.BufferedSource
    import okio.ForwardingTimeout
    import okio.Sink
    import okio.Source
    import okio.Timeout
    
    /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  8. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

    import okhttp3.internal.toImmutableList
    import okhttp3.internal.ws.RealWebSocket
    import okhttp3.internal.ws.WebSocketExtensions
    import okhttp3.internal.ws.WebSocketProtocol
    import okio.Buffer
    import okio.BufferedSink
    import okio.BufferedSource
    import okio.Sink
    import okio.Timeout
    import okio.buffer
    import okio.sink
    import okio.source
    
    /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  9. docs/features/interceptors.md

          }
    
          @Override public long contentLength() {
            return -1; // We don't know the compressed length in advance!
          }
    
          @Override public void writeTo(BufferedSink sink) throws IOException {
            BufferedSink gzipSink = Okio.buffer(new GzipSink(sink));
            body.writeTo(gzipSink);
            gzipSink.close();
          }
        };
      }
    }
    ```
    
    ### Rewriting Responses
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 8.1K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

    import okhttp3.internal.deleteIfExists
    import okhttp3.internal.isCivilized
    import okhttp3.internal.okHttpName
    import okhttp3.internal.platform.Platform
    import okhttp3.internal.platform.Platform.Companion.WARN
    import okio.BufferedSink
    import okio.FileNotFoundException
    import okio.FileSystem
    import okio.ForwardingFileSystem
    import okio.ForwardingSource
    import okio.Path
    import okio.Sink
    import okio.Source
    import okio.blackholeSink
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
Back to top