- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 2,107 for IsStream (0.15 sec)
-
tensorflow/compiler/mlir/tf2xla/internal/mlir_pass_instrumentation_test.cc
void runBeforePass(Pass* pass, Operation* op) override { StringStream stream; op->print(stream, mlir::OpPrintingFlags().useLocalScope()); ops_seen_by_pass_[pass] = stream.ss.str(); } void runAfterPass(Pass* pass, Operation* op) override { StringStream stream; op->print(stream, mlir::OpPrintingFlags().useLocalScope()); if (!absl::StrContains(stream.ss.str(), kTestInstrumentationSearch) &&
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Sep 19 22:54:26 UTC 2023 - 3.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/log/AdminLogAction.java
final String logFilePath = systemHelper.getLogFilePath(); if (StringUtil.isNotBlank(logFilePath)) { final Path logDirPath = Paths.get(logFilePath); try (Stream<Path> stream = Files.list(logDirPath)) { stream.filter(entry -> isLogFilename(entry.getFileName().toString())).sorted().forEach(filePath -> { final Map<String, Object> map = new HashMap<>();
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 4.7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/OsddHelperTest.java
osddHelper.setContentType("application/opensearchdescription+xml"); osddHelper.init(); assertFalse(osddHelper.hasOpenSearchFile()); try { osddHelper.asStream(); fail(); } catch (final Exception e) { assertEquals("Unsupported Open Search Description Document response.", e.getMessage()); } }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 5.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/watch.go
UseTextFraming bool // the media type this watch is being served with MediaType string // used to frame the watch stream Framer runtime.Framer // used to encode the watch stream event itself Encoder runtime.Encoder // used to encode the nested object in the watch stream EmbeddedEncoder runtime.Encoder MemoryAllocator runtime.MemoryAllocator TimeoutFactory TimeoutFactory
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 14 16:37:25 UTC 2023 - 11.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/doc.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 05 18:37:18 UTC 2023 - 2.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/thumbnail/ThumbnailAction.java
} // 404 throw responseManager.new404("Thumbnail for " + form.docId + " is under generating."); } return asStream(form.docId).contentType(getImageMimeType(thumbnailFile)).stream(out -> { try (BufferedInputStream in = new BufferedInputStream(new FileInputStream(thumbnailFile))) { out.write(in); } }); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3.6K bytes - Viewed (0) -
pkg/registry/core/pod/rest/subresources.go
limitations under the License. */ package rest import ( "context" "fmt" "net/http" "net/url" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/util/httpstream/wsstream" "k8s.io/apimachinery/pkg/util/net" "k8s.io/apimachinery/pkg/util/proxy" genericregistry "k8s.io/apiserver/pkg/registry/generic/registry" "k8s.io/apiserver/pkg/registry/rest"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 9.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/elevateword/ApiAdminElevatewordAction.java
}); final EditBody body = createEditBody(entity); final PermissionHelper permissionHelper = ComponentUtil.getPermissionHelper(); body.permissions = stream(entity.getPermissions()).get(stream -> stream.map(s -> permissionHelper.decode(s)) .filter(StringUtil::isNotBlank).distinct().collect(Collectors.joining("\n")));
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.6K bytes - Viewed (0) -
internal/s3select/sql/jsonpath_test.go
"io" "os" "path/filepath" "reflect" "testing" "github.com/alecthomas/participle" "github.com/bcicen/jstream" ) func getJSONStructs(b []byte) ([]interface{}, error) { dec := jstream.NewDecoder(bytes.NewBuffer(b), 0).ObjectAsKVS() var result []interface{} for parsedVal := range dec.Stream() { result = append(result, parsedVal.Value) } if err := dec.Err(); err != nil { return nil, err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 2.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/elevateword/AdminElevatewordAction.java
BeanUtil.copyBeanToBean(form, entity, op -> op.exclude(Stream .concat(Stream.of(Constants.COMMON_CONVERSION_RULE), Stream.of(Constants.PERMISSIONS)).toArray(n -> new String[n]))); final PermissionHelper permissionHelper = ComponentUtil.getPermissionHelper(); entity.setPermissions(split(form.permissions, "\n").get(
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 18.7K bytes - Viewed (0)