- Sort Score
- Result 10 results
- Languages All
Results 321 - 330 of 1,027 for Closer (0.36 sec)
-
samples/slack/src/main/java/okhttp3/slack/RtmSession.java
webSocket.close(1000, null); System.out.println("onClose (" + code + "): " + reason); } @Override public void onFailure(WebSocket webSocket, Throwable t, Response response) { // TODO(jwilson): can I read the response body? Do I have to? System.out.println("onFailure " + response); } @Override public void close() throws IOException { if (webSocket == null) return;
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Nov 19 20:16:58 UTC 2016 - 2.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/stream/StreamUtil.java
this.supplier = supplier; } /** * Executes the provided {@link Consumer} with a {@link Stream} obtained from the supplier. * The stream is automatically closed after the consumer is executed. * * @param stream the {@link Consumer} to process the {@link Stream} */ public void of(final Consumer<Stream<T>> stream) {
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 4.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComClose.java
import jcifs.internal.Request; import jcifs.internal.smb1.SMB1SigningDigest; import jcifs.internal.smb1.ServerMessageBlock; import jcifs.internal.util.SMBUtil; /** * SMB1 Close file request message. * * This command is used to close a file that was previously opened * with an Open command. */ public class SmbComClose extends ServerMessageBlock implements Request<SmbComBlankResponse> {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 3.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketRecorder.kt
val delegate = delegate if (delegate != null) { this.delegate = null delegate.onClosed(webSocket, code, reason) } else { events.add(Closed(code, reason)) } } override fun onFailure( webSocket: WebSocket, t: Throwable, response: Response?, ) { Platform.get().log("[WS $name] onFailure", Platform.INFO, t)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6.8K bytes - Viewed (0) -
src/test/java/jcifs/smb1/dcerpc/msrpc/LsaPolicyHandleTest.java
doThrow(new IOException("Close network error")).when(mockDcerpcHandle).sendrecv(any(MsrpcLsarClose.class)); // Act & Assert IOException thrown = assertThrows(IOException.class, () -> { handle.close(); }); assertEquals("Close network error", thrown.getMessage());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 7.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/MessageInflater.kt
// We cannot read all, as the source does not close. // Instead, we ensure that all bytes from source have been processed by inflater. do { inflaterSource.readOrInflate(buffer, Long.MAX_VALUE) } while (inflater.bytesRead < totalBytesToRead && !inflater.finished()) } @Throws(IOException::class) override fun close() = inflaterSource.close()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 1.8K bytes - Viewed (0) -
src/test/java/org/codelibs/curl/io/ContentOutputStreamTest.java
ContentOutputStream cos = new ContentOutputStream(10, Curl.tmpDir); cos.write(new byte[] { 0, 1, 2, 3, 4 }); assertFalse(cos.done); assertTrue(cos.isInMemory()); cos.close(); assertFalse(cos.done); } @Test public void inFile() throws IOException { ContentOutputStream cos = new ContentOutputStream(10, Curl.tmpDir);
Registered: Thu Sep 04 15:34:10 UTC 2025 - Last Modified: Sat May 10 01:44:04 UTC 2025 - 2K bytes - Viewed (0) -
api/next/67546.txt
pkg database/sql/driver, type RowsColumnScanner interface { Close, Columns, Next, ScanColumn } #67546 pkg database/sql/driver, type RowsColumnScanner interface, Close() error #67546 pkg database/sql/driver, type RowsColumnScanner interface, Columns() []string #67546 pkg database/sql/driver, type RowsColumnScanner interface, Next([]Value) error #67546 pkg database/sql/driver, type RowsColumnScanner interface, ScanColumn(interface{}, int) error #67546
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon Aug 11 21:27:36 UTC 2025 - 454 bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/OAuthSessionFactory.java
} public interface Listener { void sessionGranted(OAuthSession session); } @Override public void close() { if (mockWebServer == null) throw new IllegalStateException(); try { mockWebServer.close(); } catch (IOException ignored) { } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Aug 12 07:26:27 UTC 2021 - 3.8K bytes - Viewed (0) -
src/cmd/asm/internal/lex/tokenizer.go
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Thu Aug 04 20:35:21 UTC 2022 - 3K bytes - Viewed (0)