- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 186 for unwrapped (0.14 sec)
-
android/guava/src/com/google/common/collect/AbstractMapBasedMultimap.java
* <p>A subcollection, such as a sublist, contains some of the values for a given key. Its * ancestor field points to the full wrapped collection with all values for the key. The * subcollection {@code refreshIfEmpty}, {@code removeIfEmpty}, and {@code addToMap} methods call * the corresponding methods of the full wrapped collection. */ @WeakOuter class WrappedCollection extends AbstractCollection<V> {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Oct 13 14:11:58 UTC 2023 - 46.6K bytes - Viewed (0) -
src/encoding/base32/base32.go
} return offset } func (r *newlineFilteringReader) Read(p []byte) (int, error) { n, err := r.wrapped.Read(p) for n > 0 { s := p[0:n] offset := stripNewlines(s, s) if err != nil || offset > 0 { return offset, err } // Previous buffer entirely whitespace, read again n, err = r.wrapped.Read(p) } return n, err } // NewDecoder constructs a new base32 stream decoder.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 16:25:54 UTC 2024 - 15.9K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server.go
func initializeMonitoring() (prometheus.Gatherer, error) { registry := prometheus.NewRegistry() wrapped := prometheus.WrapRegistererWithPrefix("istio_agent_", registry) wrapped.MustRegister(collectors.NewProcessCollector(collectors.ProcessCollectorOpts{})) wrapped.MustRegister(collectors.NewGoCollector()) _, err := monitoring.RegisterPrometheusExporter(wrapped, registry) if err != nil { return nil, fmt.Errorf("could not setup exporter: %v", err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 31.1K bytes - Viewed (1) -
android/guava/src/com/google/common/eventbus/EventBus.java
* * <h2>Dead Events</h2> * * <p>If an event is posted, but no registered subscribers can accept it, it is considered "dead." * To give the system a second chance to handle dead events, they are wrapped in an instance of * {@link DeadEvent} and reposted. * * <p>If a subscriber for a supertype of all events (such as Object) is registered, no event will
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Aug 25 16:37:57 UTC 2021 - 12.8K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/tasks/DefaultTaskOutputs.java
}); } @Override public boolean getStoreInCache() { return storeInCache; } @Override public void doNotStoreInCache() { // Not wrapped in TaskMutator to allow calls during task execution storeInCache = false; } @Override public void cacheIf(final Spec<? super Task> spec) { cacheIf("Task outputs cacheable", spec);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 04 09:46:14 UTC 2023 - 10.2K bytes - Viewed (0) -
src/encoding/base64/base64.go
uint64(n5)<<34 | uint64(n6)<<28 | uint64(n7)<<22 | uint64(n8)<<16, true } type newlineFilteringReader struct { wrapped io.Reader } func (r *newlineFilteringReader) Read(p []byte) (int, error) { n, err := r.wrapped.Read(p) for n > 0 { offset := 0 for i, b := range p[:n] { if b != '\r' && b != '\n' { if i != offset { p[offset] = b }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 17.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
* * <p>Failure to follow this advice may result in non-deterministic behavior. * * <p>The returned queue will be serializable if the specified queue is serializable. * * @param queue the queue to be wrapped in a synchronized view * @return a synchronized view of the specified queue * @since 14.0 */ public static <E extends @Nullable Object> Queue<E> synchronizedQueue(Queue<E> queue) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 16K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/validation/metrics_test.go
f.original.ObserveRatchetingTime(1 * time.Nanosecond) f.realSum += d } func (f *fakeMetrics) Reset() []metrics.Registerable { f.realSum = 0 originalResettable, ok := f.original.(resettable) if !ok { panic("wrapped metrics must implement resettable") } return originalResettable.Reset() } type resettable interface { Reset() []metrics.Registerable } func TestMetrics(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 10.9K bytes - Viewed (0) -
src/mime/multipart/multipart.go
// next part (if any) begins. func (p *Part) Read(d []byte) (n int, err error) { return p.r.Read(d) } // partReader implements io.Reader by reading raw bytes directly from the // wrapped *Part, without doing any Transfer-Encoding decoding. type partReader struct { p *Part } func (pr partReader) Read(d []byte) (int, error) { p := pr.p br := p.mr.bufReader
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 14.1K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/CacheBuilder.java
* divided into segments, each of which does LRU internally) * <li>time-based expiration of entries, measured since last access or last write * <li>keys automatically wrapped in {@code WeakReference} * <li>values automatically wrapped in {@code WeakReference} or {@code SoftReference} * <li>notification of evicted (or otherwise removed) entries * <li>accumulation of cache access statistics * </ul> *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 15 16:12:13 UTC 2024 - 44.8K bytes - Viewed (0)