- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 652 for Closes (0.4 sec)
-
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 Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.7K 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 Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Closeables.java
* * @param inputStream the input stream to be closed, or {@code null} in which case this method * does nothing * @since 17.0 */ public static void closeQuietly(@CheckForNull InputStream inputStream) { try { close(inputStream, true); } catch (IOException impossible) { throw new AssertionError(impossible); } } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 4.7K bytes - Viewed (0) -
internal/lock/lock.go
r.mutex.Lock() r.refs++ r.mutex.Unlock() } // Close - this closer implements a special closer // closes the underlying fd only when the refs // reach zero. func (r *RLockedFile) Close() (err error) { r.mutex.Lock() defer r.mutex.Unlock() if r.refs == 0 { return os.ErrInvalid } r.refs-- if r.refs == 0 { err = r.File.Close() } return err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 2.5K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Closer.java
* * <pre>{@code * Closer closer = Closer.create(); * try { * InputStream in = closer.register(openInputStream()); * OutputStream out = closer.register(openOutputStream()); * // do stuff * } catch (Throwable e) { * // ensure that any checked exception types other than IOException that could be thrown are * // provided here, e.g. throw closer.rethrow(e, CheckedException.class);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Mar 06 15:15:46 GMT 2024 - 11.9K bytes - Viewed (0) -
internal/dsync/dsync-client_test.go
u: u, rest: rest.NewClient(u, tr, nil), } } // Close closes the underlying socket file descriptor. func (restClient *ReconnectRESTClient) IsOnline() bool { // If rest client has not connected yet there is nothing to close. return restClient.rest != nil } func (restClient *ReconnectRESTClient) IsLocal() bool { return false } // Close closes the underlying socket file descriptor.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 20 17:36:09 GMT 2022 - 4.4K bytes - Viewed (0) -
internal/ioutil/ioutil.go
w.wLimit -= int64(n1) return n, err } n1, err = w.Writer.Write(p) w.wLimit -= int64(n1) return n, err } // Close closes the LimitWriter. It behaves like io.Closer. func (w *LimitWriter) Close() error { if closer, ok := w.Writer.(io.Closer); ok { return closer.Close() } return nil } // LimitedWriter takes an io.Writer and returns an ioutil.LimitWriter.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
android/guava/src/com/google/common/io/MultiReader.java
MultiReader(Iterator<? extends CharSource> readers) throws IOException { this.it = readers; advance(); } /** Closes the current reader and opens the next one, if any. */ private void advance() throws IOException { close(); if (it.hasNext()) { current = it.next().openStream(); } } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 2.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt
* limitations under the License. */ package okhttp3 import okio.IOException /** * Listener for connection events. Extend this class to monitor the new connections and closes. * * All event methods must execute fast, without external locking, cannot throw exceptions, * attempt to mutate the event parameters, or be reentrant back into the client.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 2.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/MultiInputStream.java
advance(); } @Override public void close() throws IOException { if (in != null) { try { in.close(); } finally { in = null; } } } /** Closes the current input stream and opens the next one, if any. */ private void advance() throws IOException { close(); if (it.hasNext()) { in = it.next().openStream(); } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 2.8K bytes - Viewed (0)