- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 225 for Writer (0.25 sec)
-
android/guava-tests/test/com/google/common/io/BaseEncodingTest.java
throws IOException { StringWriter writer = new StringWriter(); try (OutputStream encodingStream = encoding.encodingStream(writer)) { encodingStream.write(decoded.getBytes(UTF_8)); } assertThat(writer.toString()).isEqualTo(encoded); } @GwtIncompatible // Reader private static void testStreamingDecodes(BaseEncoding encoding, String encoded, String decoded) throws IOException {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 24.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/CrawlingInfoService.java
} } public void exportCsv(final Writer writer) { final CsvConfig cfg = new CsvConfig(',', '"', '"'); cfg.setEscapeDisabled(false); cfg.setQuoteDisabled(false); @SuppressWarnings("resource") final CsvWriter csvWriter = new CsvWriter(writer, cfg); try { final List<String> list = new ArrayList<>();
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 13.4K bytes - Viewed (0) -
internal/grid/msg_gen.go
} // EncodeMsg implements msgp.Encodable func (z *connectReq) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 2 // write "ID" err = en.Append(0x82, 0xa2, 0x49, 0x44) if err != nil { return } err = en.WriteBytes((z.ID)[:]) if err != nil { err = msgp.WrapError(err, "ID") return } // write "Host" err = en.Append(0xa4, 0x48, 0x6f, 0x73, 0x74) if err != nil { return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 18.8K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
"istio.io/istio/pkg/log" ) type flagState interface { run(out io.Writer) error } var ( _ flagState = (*resetState)(nil) _ flagState = (*logLevelState)(nil) _ flagState = (*stackTraceLevelState)(nil) _ flagState = (*getAllLogLevelsState)(nil) ) type resetState struct { client *ControlzClient } func (rs *resetState) run(_ io.Writer) error { const ( defaultOutputLevel = "info"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CharSource.java
} @Override public long copyTo(CharSink sink) throws IOException { checkNotNull(sink); Closer closer = Closer.create(); try { Writer writer = closer.register(sink.openStream()); writer.write((String) seq); return seq.length(); } catch (Throwable e) { throw closer.rethrow(e); } finally { closer.close(); } } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 22.4K bytes - Viewed (0) -
cmd/metacache-stream.go
} return nil } return &w } // write one or more objects to the stream in order. // It is favorable to send as many objects as possible in a single write, // but no more than math.MaxUint32 func (w *metacacheWriter) write(objs ...metaCacheEntry) error { if w == nil { return errors.New("metacacheWriter: nil writer") } if len(objs) == 0 { return nil } if w.creator != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/elevateword/AdminElevatewordAction.java
try { try (Writer writer = new BufferedWriter(new OutputStreamWriter(Files.newOutputStream(tempFile), getCsvEncoding()))) { elevateWordService.exportCsv(writer); } catch (final Exception e) { logger.warn("Failed to process a request.", e);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/bucket-handlers_test.go
// if object upload fails stop the test. if err != nil { t.Fatalf("Error uploading object: <ERROR> %v", err) } // initialize httptest Recorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder() // construct HTTP request for DELETE bucket.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 39.5K bytes - Viewed (2) -
src/main/java/org/codelibs/fess/sso/saml/SamlAuthenticator.java
} return new StreamResponse("metadata").contentType("application/xhtml+xml").stream(out -> { try (final Writer writer = new OutputStreamWriter(out.stream(), Constants.UTF_8_CHARSET)) { writer.write(metadata); } }); } catch (final SsoMessageException e) { throw e;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 15.2K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
// its required to write the policies first before running tests on GetBucketPolicy. for i, testPolicy := range putTestPolicies { // obtain the put bucket policy request body. bucketPolicyStr := fmt.Sprintf(bucketPolicyTemplate, testPolicy.bucketName, testPolicy.bucketName) // initialize HTTP NewRecorder, this records any mutations to response writer inside the handler. recV4 := httptest.NewRecorder()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 32.7K bytes - Viewed (0)