- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 136 for strnames (0.12 sec)
-
platforms/core-runtime/serialization/src/test/groovy/org/gradle/internal/serialize/kryo/KryoBackedCodecTest.groovy
assert nested.readString() == "chunked" } assert decoder.readString() == "done" } } def "can encode and decode multiple byte streams"() { when: def bytes = encode { Encoder encoder -> encoder.encodeChunked { Encoder nested -> nested.writeSmallInt(1) nested.writeString("chunked") }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 5.2K bytes - Viewed (0) -
platforms/core-runtime/build-process-services/src/main/java/org/gradle/api/internal/classpath/DefaultModuleRegistry.java
} private Set<File> findDependencyJars(String moduleName, String[] jarNames) { Set<File> runtimeClasspath = new LinkedHashSet<>(); for (String jarName : jarNames) { runtimeClasspath.add(findDependencyJar(moduleName, jarName)); } return runtimeClasspath; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 06:16:07 UTC 2024 - 18.5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Comparators.java
* @since 33.2.0 (available since 22.0 in guava-jre) */ @SuppressWarnings({"AndroidJdkLibsChecker", "Java7ApiChecker"}) @IgnoreJRERequirement // Users will use this only if they're already using streams. public static <T extends @Nullable Object> Collector<T, ?, List<T>> least( int k, Comparator<? super T> comparator) { checkNonnegative(k, "k"); checkNotNull(comparator); return Collector.of(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 02 13:36:19 UTC 2024 - 10.1K bytes - Viewed (0) -
pkg/log/options.go
// The special values stdout and stderr can be used to output to the // standard I/O streams. This defaults to stdout. OutputPaths []string // ErrorOutputPaths is a list of file system paths to write logger errors to. // The special values stdout and stderr can be used to output to the // standard I/O streams. This defaults to stderr. ErrorOutputPaths []string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 07 04:04:34 UTC 2024 - 10.6K bytes - Viewed (0) -
pilot/pkg/features/tuning.go
"istio.io/istio/pkg/env" ) // Define performance tuning related features here. var ( MaxConcurrentStreams = env.Register( "ISTIO_GPRC_MAXSTREAMS", 100000, "Sets the maximum number of concurrent grpc streams.", ).Get() // MaxRecvMsgSize The max receive buffer size of gRPC received channel of Pilot in bytes. MaxRecvMsgSize = env.Register( "ISTIO_GPRC_MAXRECVMSGSIZE", 4*1024*1024,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 04:22:19 UTC 2024 - 4.8K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/es/user/cbean/bs/BsUserCB.java
doColumn("state"); } public void columnStreet() { doColumn("street"); } public void columnSurname() { doColumn("surname"); } public void columnTelephoneNumber() { doColumn("telephoneNumber"); } public void columnTeletexTerminalIdentifier() {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MoreCollectors.java
*/ @GwtCompatible @ElementTypesAreNonnullByDefault @SuppressWarnings({"AndroidJdkLibsChecker", "Java7ApiChecker"}) @IgnoreJRERequirement // Users will use this only if they're already using streams. public final class MoreCollectors { /* * TODO(lowasser): figure out if we can convert this to a concurrent AtomicReference-based * collector without breaking j2cl? */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 02 13:36:19 UTC 2024 - 5.7K bytes - Viewed (0) -
platforms/core-runtime/logging/src/integTest/groovy/org/gradle/internal/logging/console/jvm/AbstractConsoleJvmTestLoggingFunctionalTest.groovy
then: def taskOutput = getTaskOutput(result) matchesTaskOutput(taskOutput, testLogEventRegex(TestLogEvent.STARTED.consoleMarker)) } def "can group standard output streams with task if configured"() { given: buildFile << testLoggingStandardStream() file(JAVA_TEST_FILE_PATH) << javaTestClass { """ System.out.println("standard output");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 14:21:18 UTC 2024 - 8.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
// justQueueStream skips the usual stream validation before // queueing the stream on the stream channel. func justQueueStream(streams chan httpstream.Stream) func(httpstream.Stream, <-chan struct{}) error { return func(stream httpstream.Stream, replySent <-chan struct{}) error { streams <- stream return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0) -
pkg/kubeapiserver/options/authentication.go
"the authentication documentation for further details.") fs.StringVar(&o.OIDC.UsernamePrefix, oidcUsernamePrefixFlag, "", ""+ "If provided, all usernames will be prefixed with this value. If not provided, "+ "username claims other than 'email' are prefixed by the issuer URL to avoid "+ "clashes. To skip any prefixing, provide the value '-'.")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 22:40:22 UTC 2024 - 32.4K bytes - Viewed (0)