Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 148 for checkSeq (0.04 sec)

  1. internal/grid/muxclient.go

    			}
    			m.addErrorNonBlockingClose(errResp, context.Cause(m.ctx))
    			return
    		case <-pingTimer:
    			errState = !m.doPing(errResp)
    		}
    	}
    }
    
    // checkSeq will check if sequence number is correct and increment it by 1.
    func (m *muxClient) checkSeq(seq uint32) (ok bool) {
    	if seq != m.RecvSeq {
    		if debugPrint {
    			fmt.Printf("MuxID: %d client, expected sequence %d, got %d\n", m.MuxID, m.RecvSeq, seq)
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/AbstractBiMap.java

         */
    
        @Override
        @ParametricNullness
        K checkKey(@ParametricNullness K key) {
          return super.inverse.checkValue(key);
        }
    
        @Override
        @ParametricNullness
        V checkValue(@ParametricNullness V value) {
          return super.inverse.checkKey(value);
        }
    
        /**
         * @serialData the forward bimap
         */
        @GwtIncompatible
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 15:50:50 UTC 2025
    - 14.3K bytes
    - Viewed (0)
  3. cmd/dummy-data-generator_test.go

    		b, _ := io.ReadAll(r)
    		return string(b)
    	}
    	checkEq := func(a, b string) {
    		if a != b {
    			t.Fatalf("Unexpected equality failure")
    		}
    	}
    
    	checkEq(readAll(NewDummyDataGen(0, 0)), "")
    
    	checkEq(readAll(NewDummyDataGen(10, 0)), readAll(NewDummyDataGen(10, int64(len(alphabets)))))
    
    	checkEq(readAll(NewDummyDataGen(100, 0)), readAll(NewDummyDataGen(50, 0))+readAll(NewDummyDataGen(50, 50)))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/ImmutableCollection.java

          checkElementsNotNull(elements, n);
          ensureRoomFor(n);
          /*
           * The following call is not statically checked, since arraycopy accepts plain Object for its
           * parameters. If it were statically checked, the checker would still be OK with it, since
           * we're copying into a `contents` array whose type allows it to contain nulls. Still, it's
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 21.4K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/MultiInputStreamTest.java

                  public void close() throws IOException {
                    super.close();
                    counter[0]--;
                  }
                };
              }
            };
        byte[] result = ByteSource.concat(checker, checker, checker).read();
        assertThat(result).hasLength(150);
      }
    
      private void joinHelper(Integer... spans) throws Exception {
        List<ByteSource> sources = new ArrayList<>();
        int start = 0;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:44:53 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  6. docs_src/dependencies/tutorial011_py39.py

        def __call__(self, q: str = ""):
            if q:
                return self.fixed_content in q
            return False
    
    
    checker = FixedContentQueryChecker("bar")
    
    
    @app.get("/query-checker/")
    async def read_query_check(fixed_content_included: bool = Depends(checker)):
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 504 bytes
    - Viewed (0)
  7. guava-testlib/README.md

    not use beta APIs, unless you [repackage] them. **If your
    code is a library, we strongly recommend using the [Guava Beta Checker] to
    ensure that you do not use any `@Beta` APIs!**
    
    [Guava Beta Checker]: https://github.com/google/guava-beta-checker
    
    <!-- References -->
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 16 22:01:32 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

          } catch (Exception | Error unsafeFailure) { // sneaky checked exception
            thrownUnsafeFailure = unsafeFailure;
            // Catch absolutely everything and fall through to AtomicReferenceFieldUpdaterAtomicHelper.
            try {
              helper = new AtomicReferenceFieldUpdaterAtomicHelper();
            } catch (Exception // sneaky checked exception
                | Error atomicReferenceFieldUpdaterFailure) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

          } catch (Exception | Error unsafeFailure) { // sneaky checked exception
            thrownUnsafeFailure = unsafeFailure;
            // Catch absolutely everything and fall through to AtomicReferenceFieldUpdaterAtomicHelper.
            try {
              helper = new AtomicReferenceFieldUpdaterAtomicHelper();
            } catch (Exception // sneaky checked exception
                | Error atomicReferenceFieldUpdaterFailure) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  10. docs/de/docs/advanced/advanced-dependencies.md

    ## Die Instanz als Abhängigkeit verwenden { #use-the-instance-as-a-dependency }
    
    Dann könnten wir diesen `checker` in einem `Depends(checker)` anstelle von `Depends(FixedContentQueryChecker)` verwenden, da die Abhängigkeit die Instanz `checker` und nicht die Klasse selbst ist.
    
    Und beim Auflösen der Abhängigkeit ruft **FastAPI** diesen `checker` wie folgt auf:
    
    ```Python
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Tue Dec 02 17:32:56 UTC 2025
    - 10.4K bytes
    - Viewed (0)
Back to top