- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 137 for getReader (0.3 sec)
-
subprojects/core/src/main/java/org/gradle/api/internal/file/copy/FilterChain.java
*/ @Override public InputStream transform(InputStream original) { try { return ReaderInputStream.builder().setCharset(charset).setReader(transform(new InputStreamReader(original, charset))).get(); } catch (IOException e) { throw new UncheckedIOException(e); } } public boolean hasFilters() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 20 10:14:55 UTC 2024 - 5.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/resolver/MavenChainedWorkspaceReader.java
Key key = new Key(this.readers); this.repository = new WorkspaceRepository(key.getContentType(), key); } public List<WorkspaceReader> getReaders() { return readers; } public void addReader(WorkspaceReader workspaceReader) { requireNonNull(workspaceReader, "workspaceReader");
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 5.6K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go
} if lec.WatchDog != nil { lec.WatchDog.SetLeaderElection(le) } le.Run(ctx) } // GetLeader returns the identity of the last observed leader or returns the empty string if // no leader has yet been observed. // This function is for informational purposes. (e.g. monitoring, logs, etc.) func (le *LeaderElector) GetLeader() string { return le.getObservedRecord().HolderIdentity }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 16.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/spnego/SpnegoAuthenticator.java
logger.debug("principal: {}", principal); } } catch (final Exception e) { final String msg = "Failed to process Authorization Header: " + request.getHeader(Constants.AUTHZ_HEADER); if (logger.isDebugEnabled()) { logger.debug(msg); } throw new SsoLoginException(e.getMessage() + " " + msg, e); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 11.2K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/ReloadableKuromojiTokenizerFactory.java
} } } final Reader inputPending = getInputPending(); if (inputPending != ILLEGAL_STATE_READER) { tokenizer.setReader(inputPending); } tokenizer.reset(); } @Override public boolean incrementToken() throws IOException { return tokenizer.incrementToken();
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 9.5K bytes - Viewed (0) -
pilot/pkg/networking/core/tracing.go
Uri: te, HttpUpstreamType: &core.HttpUri_Cluster{ Cluster: cluster, }, Timeout: httpService.GetTimeout(), }, RequestHeadersToAdd: buildHTTPHeaders(httpService.GetHeaders()), } } // Add configured resource detectors if otelProvider.ResourceDetectors != nil { res := []*core.TypedExtensionConfig{} rd := otelProvider.ResourceDetectors
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 17:05:28 UTC 2024 - 24.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/table_test.go
crRestClient, err := rest.RESTClientFor(&crConfig) if err != nil { t.Fatal(err) } // metav1beta1 table { ret, err := crRestClient.Get(). Resource(crd.Spec.Names.Plural). SetHeader("Accept", fmt.Sprintf("application/json;as=Table;v=%s;g=%s, application/json", metav1beta1.SchemeGroupVersion.Version, metav1beta1.GroupName)). VersionedParams(&metav1beta1.TableOptions{}, parameterCodec). Do(context.TODO()).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 02 19:34:41 UTC 2021 - 18.9K bytes - Viewed (0) -
platforms/ide/ide-native/src/testFixtures/groovy/org/gradle/ide/xcode/fixtures/ProjectFile.groovy
return findGroup('Products') } PBXGroup getSources() { return findGroup('Sources') } PBXGroup getTests() { return findGroup('Tests') } PBXGroup getHeaders() { return findGroup('Headers') } private PBXGroup findGroup(String groupName) { return mainGroup.children.find { it.name == groupName } } void assertNoTargets() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:12 UTC 2023 - 11.9K bytes - Viewed (0) -
src/cmd/cgo/internal/testcarchive/carchive_test.go
if err != nil { return []string{name} } return []string{executor, name} } // genHeader writes a C header file for the C-exported declarations found in .go // source files in dir. // // TODO(golang.org/issue/35715): This should be simpler. func genHeader(t *testing.T, header, dir string) { t.Helper() // The 'cgo' command generates a number of additional artifacts,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 00:43:51 UTC 2023 - 34.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/RoleQueryHelper.java
} } protected void processHeader(final HttpServletRequest request, final Set<String> roleSet) { final String parameter = request.getHeader(headerKey); if (logger.isDebugEnabled()) { logger.debug("{}:{}", headerKey, parameter); } if (StringUtil.isNotEmpty(parameter)) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 11.5K bytes - Viewed (0)