Search Options

Results per page
Sort
Preferred Languages
Advance

Results 421 - 430 of 527 for channels (0.09 sec)

  1. android/guava/src/com/google/common/hash/HashCode.java

       * @since 14.0 (since 11.0 as {@code Hashing.padToLong(HashCode)})
       */
      public abstract long padToLong();
    
      /**
       * Returns the value of this hash code as a byte array. The caller may modify the byte array;
       * changes to it will <i>not</i> be reflected in this {@code HashCode} object or any other arrays
       * returned by this method.
       */
      // TODO(user): consider ByteString here, when that is available
      public abstract byte[] asBytes();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 19:54:59 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  2. src/archive/zip/struct.go

    	case creatorNTFS, creatorVFAT, creatorFAT:
    		mode = msdosModeToFileMode(h.ExternalAttrs)
    	}
    	if len(h.Name) > 0 && h.Name[len(h.Name)-1] == '/' {
    		mode |= fs.ModeDir
    	}
    	return mode
    }
    
    // SetMode changes the permission and mode bits for the [FileHeader].
    func (h *FileHeader) SetMode(mode fs.FileMode) {
    	h.CreatorVersion = h.CreatorVersion&0xff | creatorUnix<<8
    	h.ExternalAttrs = fileModeToUnixMode(mode) << 16
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue May 28 21:41:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/Ordering.java

     * Ordering} to be of type {@code Comparator} instead. However, at this time we have no plan to
     * <i>deprecate</i> this class.
     *
     * <p>Many replacements involve adopting {@code Stream}, and these changes can sometimes make your
     * code verbose. Whenever following this advice, you should check whether {@code Stream} could be
     * adopted more comprehensively in your code; the end result may be quite a bit simpler.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

        assert200Http2Response(execute(sanUrl), "www.wildcard.com")
        assertThat(client.connectionPool.connectionCount()).isEqualTo(1)
      }
    
      /** Network interceptors check for changes to target.  */
      @Test
      fun worksWithNetworkInterceptors() {
        client =
          client.newBuilder()
            .addNetworkInterceptor(
              Interceptor { chain: Interceptor.Chain? ->
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  5. internal/kms/config.go

    	// MINIO_KMS_SECRET_KEY_FILE is set to a path that does not exist,
    	// the server does not complain and start without a KMS config.
    	//
    	// Until the container image changes, this behavior has to be preserved.
    	if isPresent(EnvKMSSecretKey) && os.Getenv(EnvKMSSecretKey) == "" {
    		os.Unsetenv(EnvKMSSecretKey)
    	}
    	if isPresent(EnvKMSSecretKeyFile) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  6. istioctl/pkg/kubeinject/kubeinject.go

    run kube-inject over a single file that contains multiple Service,
    ConfigMap, Deployment, etc. definitions for a complex application. When in
    doubt re-run istioctl kube-inject on deployments to get the most up-to-date changes.
    
    It's best to do kube-inject when the resource is initially created.
    `,
    		Example: `  # Update resources on the fly before applying.
      kubectl apply -f <(istioctl kube-inject -f <resource.yaml>)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 21K bytes
    - Viewed (0)
  7. docs/config/README.md

    notify_elasticsearch  publish bucket notifications to Elasticsearch endpoints
    notify_redis          publish bucket notifications to Redis datastores
    ```
    
    ### Accessing configuration
    
    All configuration changes can be made using [`mc admin config` get/set/reset/export/import commands](https://github.com/minio/mc/blob/master/docs/minio-admin-complete-guide.md).
    
    #### List all config keys available
    
    ```
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 17.9K bytes
    - Viewed (1)
  8. cmd/storage-rest-client.go

    		stat = append(stat, st)
    	}
    
    	return stat, toStorageErr(err)
    }
    
    // ReadMultiple will read multiple files and send each back as response.
    // Files are read and returned in the given order.
    // The resp channel is closed before the call returns.
    // Only a canceled context or network errors returns an error.
    func (client *storageRESTClient) ReadMultiple(ctx context.Context, req ReadMultipleReq, resp chan<- ReadMultipleResp) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  9. guava/src/com/google/common/hash/HashCode.java

       * @since 14.0 (since 11.0 as {@code Hashing.padToLong(HashCode)})
       */
      public abstract long padToLong();
    
      /**
       * Returns the value of this hash code as a byte array. The caller may modify the byte array;
       * changes to it will <i>not</i> be reflected in this {@code HashCode} object or any other arrays
       * returned by this method.
       */
      // TODO(user): consider ByteString here, when that is available
      public abstract byte[] asBytes();
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 19:54:59 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  10. cmd/storage-rest-server.go

    				}
    				return
    			}
    		}
    	}()
    	return func(err error) {
    		if doneCh == nil {
    			return
    		}
    
    		// Indicate we are ready to write.
    		doneCh <- err
    
    		// Wait for channel to be closed so we don't race on writes.
    		<-doneCh
    
    		// Clear so we can be called multiple times without crashing.
    		doneCh = nil
    	}, &closeNotifier{rc: r.Body, done: bodyDoneCh}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
Back to top