- Sort Score
- Result 10 results
- Languages All
Results 511 - 520 of 770 for NEXT (0.04 sec)
-
internal/grid/connection.go
return } var next []byte next, remain, err = msgp.ReadBytesZC(remain) if err != nil { if !xnet.IsNetworkOrHostDown(err, true) { gridLogIf(ctx, fmt.Errorf("ws read merged: %w", err)) } return } m.Payload = nil subID, _, err = m.parse(next) if err != nil { if !xnet.IsNetworkOrHostDown(err, true) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
src/archive/tar/writer.go
fileState ReadFrom(io.Reader) (int64, error) } // Flush finishes writing the current file's block padding. // The current file must be fully written before Flush can be called. // // This is unnecessary as the next call to [Writer.WriteHeader] or [Writer.Close] // will implicitly flush out the file's padding. func (tw *Writer) Flush() error { if tw.err != nil { return tw.err } if nb := tw.curr.logicalRemaining(); nb > 0 {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Oct 02 14:22:59 UTC 2024 - 19.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/RangeTest.java
} private static final DiscreteDomain<Integer> UNBOUNDED_DOMAIN = new DiscreteDomain<Integer>() { @Override public Integer next(Integer value) { return integers().next(value); } @Override public Integer previous(Integer value) { return integers().previous(value); } @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 23.9K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/MultimapTestSuiteBuilder.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 26.8K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
bucket := buckets[i].Name updated := false meta, err := loadBucketMetadata(ctx, sys.objAPI, bucket) if err != nil { internalLogIf(ctx, err, logger.WarningKind) wait() // wait to proceed to next entry. continue } sys.Lock() // Update if the bucket metadata in the memory is older than on-disk one if lu := sys.metadataMap[bucket].lastUpdate(); lu.Before(meta.lastUpdate()) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 20.4K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/Trans2FindFirst2Response.java
* or to the start of the entry containing the * filename(e.g. NT). Ahhrg! In either case the * lastNameOffset falls between the start of the * entry and the next entry. */ if( lastNameBufferIndex >= bufferIndex && ( e.nextEntryOffset == 0 || lastNameBufferIndex < ( bufferIndex + e.nextEntryOffset ))) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 8.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/MultimapPutTester.java
Iterator<Entry<K, Collection<V>>> asMapItr = multimap().asMap().entrySet().iterator(); Collection<V> collection = null; while (asMapItr.hasNext()) { Entry<K, Collection<V>> asMapEntry = asMapItr.next(); if (key.equals(asMapEntry.getKey())) { collection = asMapEntry.getValue(); break; } } assertNotNull(collection);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 7.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/CollectionAddAllTester.java
ConcurrentModificationException.class, () -> { Iterator<E> iterator = collection.iterator(); assertTrue(collection.addAll(MinimalCollection.of(e3(), e0()))); iterator.next(); }); } @CollectionFeature.Require(absent = SUPPORTS_ADD) @CollectionSize.Require(absent = ZERO) public void testAddAll_unsupportedAllPresent() { try { assertFalse(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 7.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
class WebSocketRecorder( private val name: String, ) : WebSocketListener() { private val events = LinkedBlockingQueue<Any>() private var delegate: WebSocketListener? = null /** Sets a delegate for handling the next callback to this listener. Cleared after invoked. */ fun setNextEventDelegate(delegate: WebSocketListener?) { this.delegate = delegate } override fun onOpen( webSocket: WebSocket,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.9K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/google/MultimapPutTester.java
Iterator<Entry<K, Collection<V>>> asMapItr = multimap().asMap().entrySet().iterator(); Collection<V> collection = null; while (asMapItr.hasNext()) { Entry<K, Collection<V>> asMapEntry = asMapItr.next(); if (key.equals(asMapEntry.getKey())) { collection = asMapEntry.getValue(); break; } } assertNotNull(collection);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 7.2K bytes - Viewed (0)