Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 105 for clicker (0.32 seconds)

  1. internal/hash/checker.go

    )
    
    // Checker allows to verify the checksum of a reader.
    type Checker struct {
    	c io.Closer
    	r io.Reader
    	h hash.Hash
    
    	want []byte
    }
    
    // NewChecker ensures that content with the specified length is read from rc.
    // Calling Close on this will close upstream.
    func NewChecker(rc io.ReadCloser, h hash.Hash, wantSum []byte, length int64) *Checker {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jan 20 14:49:07 GMT 2025
    - 1.8K bytes
    - Click Count (0)
  2. guava/src/com/google/common/base/Ticker.java

     */
    @GwtCompatible
    public abstract class Ticker {
      /** Constructor for use by subclasses. */
      protected Ticker() {}
    
      /** Returns the number of nanoseconds elapsed since this ticker's fixed point of reference. */
      public abstract long read();
    
      /**
       * A ticker that reads the current time using {@link System#nanoTime}.
       *
       * @since 10.0
       */
      public static Ticker systemTicker() {
        return SYSTEM_TICKER;
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1.8K bytes
    - Click Count (0)
  3. internal/dsync/locker.go

    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package dsync
    
    import "context"
    
    // NetLocker is dsync compatible locker interface.
    type NetLocker interface {
    	// Do read lock for given LockArgs.  It should return
    	// * a boolean to indicate success/failure of the operation
    	// * an error on failure of lock request operation.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Jan 18 20:44:38 GMT 2022
    - 2.7K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/base/Ticker.java

     */
    @GwtCompatible
    public abstract class Ticker {
      /** Constructor for use by subclasses. */
      protected Ticker() {}
    
      /** Returns the number of nanoseconds elapsed since this ticker's fixed point of reference. */
      public abstract long read();
    
      /**
       * A ticker that reads the current time using {@link System#nanoTime}.
       *
       * @since 10.0
       */
      public static Ticker systemTicker() {
        return SYSTEM_TICKER;
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1.8K bytes
    - Click Count (0)
  5. docs_src/dependencies/tutorial011_py310.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)):
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Feb 12 13:19:43 GMT 2026
    - 504 bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        // waiting for the slow interrupting thread to complete Thread.interrupt
        awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);
    
        Blocker blocker = (Blocker) LockSupport.getBlocker(runner);
        Thread owner = blocker.getOwner();
        assertThat(owner).isSameInstanceAs(interrupter);
    
        slowChannel.exitClose.countDown(); // release the interrupter
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java

        // waiting for the slow interrupting thread to complete Thread.interrupt
        awaitBlockedOnInstanceOf(runner, InterruptibleTask.Blocker.class);
    
        Blocker blocker = (Blocker) LockSupport.getBlocker(runner);
        Thread owner = blocker.getOwner();
        assertThat(owner).isSameInstanceAs(interrupter);
    
        slowChannel.exitClose.countDown(); // release the interrupter
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  8. internal/dsync/drwmutex_test.go

    	runtime.GOMAXPROCS(gomaxprocs)
    	m := NewDRWMutex(ds, "test-parallel")
    
    	clocked := make(chan bool)
    	cunlock := make(chan bool)
    	cdone := make(chan bool)
    	for range numReaders {
    		go parallelReader(context.Background(), m, clocked, cunlock, cdone)
    	}
    	// Wait for all parallel RLock()s to succeed.
    	for range numReaders {
    		<-clocked
    	}
    	for range numReaders {
    		cunlock <- true
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.4K bytes
    - Click Count (0)
  9. docs_src/dependencies/tutorial011_an_py310.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: Annotated[bool, Depends(checker)]):
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Feb 12 13:19:43 GMT 2026
    - 544 bytes
    - Click Count (0)
  10. 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 -->
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 16 22:01:32 GMT 2025
    - 1.7K bytes
    - Click Count (0)
Back to Top