- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 512 for reading_ (0.18 sec)
-
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSourceListener.kt
* TODO description. * * No further calls to this listener will be made. */ open fun onClosed(eventSource: EventSource) { } /** * Invoked when an event source has been closed due to an error reading from or writing to the * network. Incoming events may have been lost. No further calls to this listener will be made. */ open fun onFailure( eventSource: EventSource, t: Throwable?,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.5K bytes - Viewed (0) -
architecture/networking/pilot.md
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Feb 07 17:53:24 UTC 2024 - 19.1K bytes - Viewed (0) -
src/archive/zip/example_test.go
log.Fatal(err) } } // Make sure to check the error on Close. err := w.Close() if err != nil { log.Fatal(err) } } func ExampleReader() { // Open a zip archive for reading. r, err := zip.OpenReader("testdata/readme.zip") if err != nil { log.Fatal(err) } defer r.Close() // Iterate through the files in the archive, // printing some of their contents.
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Jan 27 00:22:03 UTC 2016 - 2K bytes - Viewed (0) -
guava/src/com/google/common/collect/LinkedHashMultimap.java
valueSetCapacity = DEFAULT_VALUE_SET_CAPACITY; int distinctKeys = stream.readInt(); Map<K, Collection<V>> map = Platform.newLinkedHashMapWithExpectedSize(12); for (int i = 0; i < distinctKeys; i++) { @SuppressWarnings("unchecked") K key = (K) stream.readObject(); map.put(key, createCollection(key)); } int entries = stream.readInt(); for (int i = 0; i < entries; i++) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 24.3K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/xml/XmlReaderException.java
*/ package org.apache.maven.api.services.xml; import org.apache.maven.api.annotations.Experimental; import org.apache.maven.api.services.MavenException; /** * An exception thrown during the reading of an xml file. * * @since 4.0.0 */ @Experimental public class XmlReaderException extends MavenException { private final Location location; /**
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Mon Mar 25 10:50:01 UTC 2024 - 1.4K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Closeables.java
* * <p>While it's not safe in the general case to ignore exceptions that are thrown when closing an * I/O resource, it should generally be safe in the case of a resource that's being used only for * reading, such as an {@code InputStream}. Unlike with writable resources, there's no chance that * a failure that occurs when closing the stream indicates a meaningful problem such as a failure
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 4.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
var complete = (upstream == null) /** The most recently read bytes from [upstream]. This is a suffix of [file]. Guarded by this. */ val buffer = Buffer() /** * Reference count of the number of active sources reading this stream. When decremented to 0 * resources are released and all following calls to [.newSource] return null. Guarded by this. */ var sourceCount = 0 val isClosed: Boolean get() = file == null
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 11.8K bytes - Viewed (0) -
docs/en/docs/tutorial/dependencies/global-dependencies.md
## Dependencies for groups of *path operations*
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 1.4K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt
import okio.ByteString import okio.ByteString.Companion.decodeHex import okio.FileSystem import okio.Path import okio.Path.Companion.toOkioPath import okio.buffer import okio.source /** * Utilities for reading HPACK tests. */ object HpackJsonUtil { @Suppress("unused") private val MOSHI = Moshi.Builder() .add( object : Any() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.3K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental_reader.h
// test(); // int64_t value = TFE_MonitoringReadCounter1(reader, "label-value"); // Opaque handle to a reader. typedef struct TFE_MonitoringCounterReader TFE_MonitoringCounterReader; // Returns a handle to be used for reading values from streamz counter. The // counter can have been created with any number of labels. TF_CAPI_EXPORT extern TFE_MonitoringCounterReader* TFE_MonitoringNewCounterReader(const char* name);
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Thu Apr 20 03:14:47 UTC 2023 - 2.3K bytes - Viewed (0)