- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 23 for texts (0.13 sec)
-
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
@Tag("Slow") class RealWebSocketTest { // NOTE: Fields are named 'client' and 'server' for cognitive simplicity. This differentiation has // zero effect on the behavior of the WebSocket API which is why tests are only written once // from the perspective of a single peer. private val random = Random(0) private val client2Server = Pipe(8192L) private val server2client = Pipe(8192L) private val taskFaker = TaskFaker()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
val e = RuntimeException() clientListener.setNextEventDelegate( object : WebSocketListener() { override fun onMessage( webSocket: WebSocket, text: String, ) { throw e } }, ) server.send("Hello, WebSockets!") clientListener.assertFailure(e) serverListener.assertFailure(EOFException::class.java)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 35.2K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
} listener.onClosing(this, code, reason) } // Writer methods to enqueue frames. They'll be sent asynchronously by the writer thread. override fun send(text: String): Boolean { return send(text.encodeUtf8(), OPCODE_TEXT) } override fun send(bytes: ByteString): Boolean { return send(bytes, OPCODE_BINARY) } @Synchronized private fun send( data: ByteString,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
.github/workflows/containers.yml
with: distribution: 'zulu' java-version: 17 - name: Setup Gradle uses: gradle/actions/setup-gradle@v3 - name: Run Container Tests
Others - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Mar 23 12:00:11 GMT 2024 - 911 bytes - Viewed (0) -
settings.gradle.kts
val graalBuild: String by settings val loomBuild: String by settings if (androidBuild.toBoolean()) { include(":regression-test") } if (graalBuild.toBoolean()) { include(":native-image-tests") } include(":okcurl") include(":okhttp") include(":okhttp-bom") include(":okhttp-brotli") include(":okhttp-coroutines") include(":okhttp-dnsoverhttps") include(":okhttp-hpacktests")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Apr 14 14:24:05 GMT 2024 - 2.6K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/WebSocketEcho.java
webSocket.send("...World!"); webSocket.send(ByteString.decodeHex("deadbeef")); webSocket.close(1000, "Goodbye, World!"); } @Override public void onMessage(WebSocket webSocket, String text) { System.out.println("MESSAGE: " + text); } @Override public void onMessage(WebSocket webSocket, ByteString bytes) { System.out.println("MESSAGE: " + bytes.hex()); }
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 04 11:40:21 GMT 2024 - 1.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt
@Test fun webSocket() { val webSocket = object : WebSocket { override fun request(): Request = TODO() override fun queueSize(): Long = TODO() override fun send(text: String): Boolean = TODO() override fun send(bytes: ByteString): Boolean = TODO() override fun close( code: Int, reason: String?, ): Boolean = TODO()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 46.5K bytes - Viewed (4) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
* after [Builder.build] for all new connections. * * @param sendConnectionPreface true to send connection preface frames. This should always be true * except for in tests that don't check for a connection preface. * @param taskRunner the TaskRunner to use, daemon by default. */ @Throws(IOException::class) @JvmOverloads fun start(sendConnectionPreface: Boolean = true) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
if (parentFile == directory) return true return parentFile.isDescendentOf(directory) } /** * See FinalizationTester for discussion on how to best trigger GC in tests. * https://android.googlesource.com/platform/libcore/+/master/support/src/test/java/libcore/ * java/lang/ref/FinalizationTester.java */ @Throws(Exception::class) @JvmStatic fun awaitGarbageCollection() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CacheTest.kt
import assertk.assertions.isNull import assertk.assertions.isTrue import java.io.IOException import java.net.CookieManager import java.net.HttpURLConnection import java.net.ResponseCache import java.text.DateFormat import java.text.SimpleDateFormat import java.util.Date import java.util.Locale import java.util.TimeZone import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicReference
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 108.6K bytes - Viewed (0)