Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 515 for awaiter (0.09 sec)

  1. guava/src/com/google/common/hash/MessageDigestHashFunction.java

    import java.io.Serializable;
    import java.nio.ByteBuffer;
    import java.security.MessageDigest;
    import java.security.NoSuchAlgorithmException;
    import java.util.Arrays;
    
    /**
     * {@link HashFunction} adapter for {@link MessageDigest} instances.
     *
     * @author Kevin Bourrillion
     * @author Dimitris Andreou
     */
    @Immutable
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed May 25 20:32:46 UTC 2022
    - 5K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/compare/route.go

    import (
    	"bytes"
    	"fmt"
    	"time"
    
    	"github.com/pmezard/go-difflib/difflib"
    
    	"istio.io/istio/pkg/util/protomarshal"
    )
    
    // RouteDiff prints a diff between Istiod and Envoy routes to the passed writer
    func (c *Comparator) RouteDiff() error {
    	envoyBytes, istiodBytes := &bytes.Buffer{}, &bytes.Buffer{}
    	envoyRouteDump, err := c.envoy.GetDynamicRouteDump(true)
    	if err != nil {
    		envoyBytes.WriteString(err.Error())
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Mar 12 10:02:09 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  3. src/archive/tar/common.go

    // A Header represents a single header in a tar archive.
    // Some fields may not be populated.
    //
    // For forward compatibility, users that retrieve a Header from Reader.Next,
    // mutate it in some ways, and then pass it back to Writer.WriteHeader
    // should do so by creating a new Header and copying the fields
    // that they are interested in preserving.
    type Header struct {
    	// Typeflag is the type of header entry.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 13 21:03:27 UTC 2024
    - 24.5K bytes
    - Viewed (0)
  4. android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

                      startLatch.countDown();
                      startLatch.await();
                      callable.call();
                      doneLatch.countDown();
                      return null;
                    }
                  });
        }
        doneLatch.await();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 22 13:49:09 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java

              return false;
            } else {
              long now = System.nanoTime();
              NANOSECONDS.timedWait(lock, nanos);
              nanos -= System.nanoTime() - now; // subtract the actual time we waited
            }
          }
        }
      }
    
      /**
       * Checks if the executor has been shut down and increments the running task count.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  6. cmd/bitrot-whole.go

    		return 0, err
    	}
    	_, err = b.Hash.Write(p)
    	if err != nil {
    		return 0, err
    	}
    	return len(p), nil
    }
    
    func (b *wholeBitrotWriter) Close() error {
    	return nil
    }
    
    // Returns whole-file bitrot writer.
    func newWholeBitrotWriter(disk StorageAPI, volume, filePath string, algo BitrotAlgorithm, shardSize int64) io.WriteCloser {
    	return &wholeBitrotWriter{disk, volume, filePath, shardSize, algo.New()}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  7. cmd/bucket-replication-utils_gen.go

    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *BucketReplicationResyncStatus) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 4
    	// write "v"
    	err = en.Append(0x84, 0xa1, 0x76)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.Version)
    	if err != nil {
    		err = msgp.WrapError(err, "Version")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 61.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

                })
            .start();
    
        // wait for the computingEntry to be created
        computationStarted.await();
        cache.invalidateAll();
        // let the computation proceed
        computingLatch.countDown();
        // don't check cache.size() until we know the get("b") call is complete
        computationComplete.await();
    
        // At this point, the listener should be holding the seed value (a -> a), and the map should
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 15:00:32 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  9. docs/pt/docs/advanced/events.md

    with open("file.txt") as file:
        file.read()
    ```
    
    Nas versões mais recentes de Python, há também um **gerenciador de contexto assíncrono**. Você o usaria com `async with`:
    
    ```Python
    async with lifespan(app):
        await do_stuff()
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  10. docs/en/docs/advanced/events.md

    ```Python
    with open("file.txt") as file:
        file.read()
    ```
    
    In recent versions of Python, there's also an **async context manager**. You would use it with `async with`:
    
    ```Python
    async with lifespan(app):
        await do_stuff()
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 28 10:36:22 UTC 2024
    - 7.6K bytes
    - Viewed (0)
Back to top