- Sort Score
- Result 10 results
- Languages All
Results 421 - 430 of 527 for channels (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)