- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 495 for closest (0.18 sec)
-
src/test/java/org/codelibs/core/io/CloseableUtilTest.java
CloseableUtil.close(out); } private static class NotifyOutputStream extends OutputStream { private String notify_; @Override public void write(final int arg0) throws IOException { } @Override public void close() throws IOException { super.close(); notify_ = "closed"; }
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 2.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/ByteSinkTest.java
TestInputStream in = new TestInputStream(new ByteArrayInputStream(new byte[10])); assertFalse(in.closed()); sink.writeFrom(in); assertFalse(in.closed()); } public void testClosesOnErrors_copyingFromByteSourceThatThrows() { for (TestOption option : EnumSet.of(OPEN_THROWS, READ_THROWS, CLOSE_THROWS)) { TestByteSource failSource = new TestByteSource(new byte[10], option);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/EventListener.kt
* response body is empty this is invoked immediately before returning that to the application. * * If the application closes the response body before attempting a read, this is invoked at the * time it is closed. * * The connection is implicit, and will generally relate to the last [connectionAcquired] event. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15.2K bytes - Viewed (0) -
internal/http/check_port_others.go
l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil { return err } // As we are able to listen on this network, the port is not in use. // Close the listener and continue check other networks. return l.Close()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
synchronized(this) { queueSize -= message.data.size.toLong() } } else if (messageOrClose is Close) { val close = messageOrClose as Close writer!!.writeClose(close.code, close.reason) // We closed the writer: now both reader and writer are closed. if (streamsToClose != null) { listener.onClosed(this, receivedCloseCode, receivedCloseReason!!) }
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) -
okhttp-testing-support/src/main/kotlin/okhttp3/CallEvent.kt
@SuppressSignatureCheck sealed class CallEvent { abstract val timestampNs: Long abstract val call: Call val name: String get() = javaClass.simpleName /** Returns if the event closes this event, or null if this is no open event. */ open fun closes(event: CallEvent): Boolean? = null data class ProxySelectStart( override val timestampNs: Long, override val call: Call, val url: HttpUrl, ) : CallEvent()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
new ClosingCallable<TestCloseable>() { @Override public TestCloseable call(DeferredCloser closer) throws Exception { closer.eventuallyClose(closeable1, closingExecutor); closer.eventuallyClose(closeable2, closingExecutor); return closeable3; } }, executor)
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 75.3K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java
* writes to, reads from, and closes the pipe in a single operation. * <li> <code>TransactNamedPipe</code> A message-type pipe call that * writes to and reads from an existing pipe descriptor in one operation. * <li> <code>CreateFile</code>, <code>ReadFile</code>, * <code>WriteFile</code>, and <code>CloseFile</code> A byte-type pipe can * be opened, written to, read from and closed using the standard Win32
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 7.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt
@SuppressSignatureCheck sealed class ConnectionEvent { abstract val timestampNs: Long open val connection: Connection? get() = null /** Returns if the event closes this event, or null if this is no open event. */ open fun closes(event: ConnectionEvent): Boolean? = null val name: String get() = javaClass.simpleName data class ConnectStart( override val timestampNs: Long, val route: Route,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue27340.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. //go:build cgo // Failed to resolve typedefs consistently. // No runtime test; just make sure it compiles. package cgotest import "cmd/cgo/internal/test/issue27340"
Go - Registered: Tue Mar 26 11:13:08 GMT 2024 - Last Modified: Fri May 12 12:00:02 GMT 2023 - 377 bytes - Viewed (0)