- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 322 for sena (0.03 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt
taskFaker.runTasks() assertThat(client.closed).isTrue() server.listener.assertExhausted() // Client should not have sent second close. client.listener.assertExhausted() // Server should not have sent second close. } @Test fun serverCloseBreaksReadMessageLoop() { server.webSocket!!.send("Hello!") server.webSocket!!.close(1000, "Bye!") assertThat(client.processNextFrame()).isTrue()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 18.7K bytes - Viewed (0) -
src/test/java/jcifs/smb/DirFileEntryEnumIterator1Test.java
// Verify interactions verify(tree, times(1)).send(isA(Trans2FindFirst2.class), any(Trans2FindFirst2Response.class)); // Verify that Trans2FindNext2 was sent twice for fetching more entries verify(tree, times(2)).send(isA(Trans2FindNext2.class), any(Trans2FindFirst2Response.class)); // Close should have sent FindClose2 exactly once
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 12.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/NotificationHelper.java
logger.debug("Sent {} to {}.", body, url); } } else { logger.warn("Failed to send {} to {}. HTTP Status is {}. {}", body, url, response.getHttpStatusCode(), response.getContentAsString()); } } catch (final IOException e) { logger.warn("Failed to send {} to {}.", body, url, e); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 6.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
} // Writer methods to enqueue frames. They'll be sent asynchronously by the writer thread. override fun send(text: String): Boolean = send(text.encodeUtf8(), OPCODE_TEXT) override fun send(bytes: ByteString): Boolean = send(bytes, OPCODE_BINARY) @Synchronized private fun send( data: ByteString, formatOpcode: Int, ): Boolean { // Don't send new frames after we've failed or enqueued a close frame.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 21.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt
flags = FLAG_ACK, ) sink.flush() } } /** * HTTP/2 only. Send a push promise header block. * * A push promise contains all the headers that pertain to a server-initiated request, and a * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as * a part of the response to `streamId`. The `promisedStreamId` has a priority of one greater than
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbFileOutputStreamTest.java
byte[] data = "Appended".getBytes(); // When outputStream.write(data); // Then - verify write request was sent verify(mockTreeHandle, atLeastOnce()).send(any(Smb2WriteRequest.class), any()); } @Test void testMultipleWrites() throws IOException, CIFSException { // Given
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt
server.send(message3) clientListener.assertTextMessage(message3) // Empty client to server message. val message4 = "" client.send(message4) serverListener.assertTextMessage(message4) // Server to client message that shares context with message1. val message5 = message1 + message1 server.send(message5) clientListener.assertTextMessage(message5)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 35.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/SmbDirectNegotiateRequest.java
} /** * Get the preferred size for send operations * * @return preferred send size in bytes */ public int getPreferredSendSize() { return preferredSendSize; } /** * Set the preferred size for send operations * * @param preferredSendSize preferred send size in bytes */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 5.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
exchange.finishRequest() } } catch (e: IOException) { if (e is ConnectionShutdownException) { throw e // No request was sent so there's no response to read. } if (!exchange.hasFailure) { throw e // Don't attempt to read the response; we failed to send the request. } sendRequestException = e } try { if (responseBuilder == null) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 7.8K bytes - Viewed (0) -
src/main/java/org/codelibs/curl/Curl.java
*/ protected Curl() { // nothing } /** * Creates a new CurlRequest with the HTTP GET method for the specified URL. * * @param url the URL to send the GET request to * @return a CurlRequest object configured with the GET method and the specified URL */ public static CurlRequest get(final String url) { return new CurlRequest(Method.GET, url); }
Registered: Thu Sep 04 15:34:10 UTC 2025 - Last Modified: Sat Jul 05 01:38:18 UTC 2025 - 5.5K bytes - Viewed (0)