Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 131 - 140 of 227 for nowrap (0.04 seconds)

  1. guava/src/com/google/common/collect/ArrayListMultimap.java

     * implement {@link java.util.RandomAccess}.
     *
     * <p>This class is not threadsafe when any concurrent operations update the multimap. Concurrent
     * read operations will work correctly. To allow concurrent update operations, wrap your multimap
     * with a call to {@link Multimaps#synchronizedListMultimap}.
     *
     * <p>See the Guava User Guide article on <a href=
     * "https://github.com/google/guava/wiki/NewCollectionTypesExplained#multimap">{@code Multimap}</a>.
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Dec 05 23:15:58 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  2. internal/http/server.go

    		if listenErrs[i] != nil {
    			listenErrCallback(srv.Addrs[i], listenErrs[i])
    		} else {
    			interfaceFound = true
    		}
    	}
    	if !interfaceFound {
    		return nil, errors.New("no available interface found")
    	}
    
    	// Wrap given handler to do additional
    	// * return 503 (service unavailable) if the server in shutdown.
    	wrappedHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    		// If server is in shutdown.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  3. api/go1.18.txt

    pkg go/types, func NewTypeParam(*TypeName, Type) *TypeParam
    pkg go/types, func NewUnion([]*Term) *Union
    pkg go/types, method (*ArgumentError) Error() string
    pkg go/types, method (*ArgumentError) Unwrap() error
    pkg go/types, method (*Interface) IsComparable() bool
    pkg go/types, method (*Interface) IsImplicit() bool
    pkg go/types, method (*Interface) IsMethodSet() bool
    pkg go/types, method (*Interface) MarkImplicit()
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Feb 17 20:31:46 GMT 2023
    - 13K bytes
    - Click Count (0)
  4. internal/hash/reader.go

    		}
    		if r.size >= 0 && size >= 0 && r.size != size {
    			return nil, SizeMismatch{Want: r.size, Got: size}
    		}
    
    		r.checksum = MD5
    		r.contentSHA256 = SHA256
    		if r.size < 0 && size >= 0 {
    			r.src = etag.Wrap(ioutil.HardLimitReader(r.src, size), r.src)
    			r.size = size
    		}
    		if r.actualSize <= 0 && actualSize >= 0 {
    			r.actualSize = actualSize
    		}
    		return r, nil
    	}
    
    	if size >= 0 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/collect/MutableClassToInstanceMap.java

        return cast(type, get(type));
      }
    
      @CanIgnoreReturnValue
      private static <T> @Nullable T cast(Class<T> type, @Nullable Object value) {
        return Primitives.wrap(type).cast(value);
      }
    
        private Object writeReplace() {
        return new SerializedForm<>(delegate());
      }
    
        private void readObject(ObjectInputStream stream) throws InvalidObjectException {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Aug 11 22:10:29 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  6. tests/connpool_test.go

    //
    //	func (c *wrapperConnPool) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error) {
    //		 return c.db.BeginTx(ctx, opts)
    //	}
    //
    // You should use BeginTx returned gorm.Tx which could wrap *sql.Tx then you can record all queries.
    func (c *wrapperConnPool) BeginTx(ctx context.Context, opts *sql.TxOptions) (gorm.ConnPool, error) {
    	tx, err := c.db.BeginTx(ctx, opts)
    	if err != nil {
    		return nil, err
    	}
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun May 25 07:40:40 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/io/ByteSource.java

        return concat(ImmutableList.copyOf(sources));
      }
    
      /**
       * Returns a view of the given byte array as a {@link ByteSource}. To view only a specific range
       * in the array, use {@code ByteSource.wrap(b).slice(offset, length)}.
       *
       * <p>Note that the given byte array may be passed directly to methods on, for example, {@code
       * OutputStream} (when {@code copyTo(OutputStream)} is called on the resulting {@code
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.7K bytes
    - Click Count (0)
  8. internal/grid/types.go

    	}()
    	enc := json.NewEncoder(buf)
    	err = enc.Encode(j.val)
    	if err != nil {
    		return b, err
    	}
    	return msgp.AppendBytes(b, buf.Bytes()), nil
    }
    
    // UnmarshalMsg will JSON marshal the value and wrap as a msgp byte array.
    // Nil values are supported.
    func (j *JSON[T]) UnmarshalMsg(bytes []byte) ([]byte, error) {
    	if bytes, err := msgp.ReadNilBytes(bytes); err == nil {
    		if j.val != nil {
    			j.p.pool.Put(j.val)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.5K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/base/FinalizableReferenceQueueClassLoaderUnloadingTest.java

        Class<?> sepFwrC = sepLoader.loadClass(MyFinalizableWeakReference.class.getName());
        Constructor<?> sepFwrCons = sepFwrC.getConstructor(Object.class, sepFrqC);
        // The object that we will wrap in FinalizableWeakReference is a Stopwatch.
        Class<?> sepStopwatchC = sepLoader.loadClass(Stopwatch.class.getName());
        assertThat(sepLoader).isSameInstanceAs(sepStopwatchC.getClassLoader());
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 7.6K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/HttpUpgradesTest.kt

      private val handshakeCertificates = platform.localhostHandshakeCertificates()
      private var client =
        clientTestRule
          .newClientBuilder()
          .eventListenerFactory(clientTestRule.wrap(eventRecorder))
          .build()
    
      fun executeAndCheckUpgrade(request: Request) {
        val socketHandler =
          MockSocketHandler()
            .apply {
              receiveRequest("client says hello\n")
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 9.6K bytes
    - Click Count (0)
Back to Top