Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 191 for Flush (0.02 sec)

  1. src/main/java/org/codelibs/fess/app/service/ElevateWordService.java

                            list.add(StringUtil.EMPTY);
                        } else {
                            list.add(value.toString());
                        }
                    }
                });
    
                csvWriter.flush();
            } catch (final IOException e) {
                logger.warn("Failed to write a sugget elevate word.", e);
            }
        }
    
        /**
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/io/ByteStreams.java

       */
      private static final int ZERO_COPY_CHUNK_SIZE = 512 * 1024;
    
      private ByteStreams() {}
    
      /**
       * Copies all bytes from the input stream to the output stream. Does not close or flush either
       * stream.
       *
       * <p><b>Java 9 users and later:</b> this method should be treated as deprecated; use the
       * equivalent {@link InputStream#transferTo} method instead.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/dict/mapping/CharMappingFileTest.java

            Writer writer = null;
            try {
                writer = new OutputStreamWriter(new FileOutputStream(testFile), Constants.UTF_8);
                writer.write(content);
                writer.flush();
            } finally {
                CloseableUtil.closeQuietly(writer);
            }
        }
    
        // Helper method to assert arrays are equal (handles sorting)
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 18.5K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java

                final byte[] buf = new byte[1024];
                int length;
                while (-1 < (length = in.read(buf))) {
                    out.write(buf, 0, length);
                    out.flush();
                }
            } catch (final IOException e) {
                throw new IORuntimeException(e);
            }
        }
    
        /**
         * Returns whether SIDs (Security Identifiers) should be resolved.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Sep 18 09:30:45 UTC 2025
    - 23K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java

                    }
                }
                return null;
            }
    
            @Override
            public void close() {
                try {
                    writer.flush();
                } catch (final IOException e) {
                    // ignore
                }
                CloseableUtil.closeQuietly(writer);
    
                if (isCommit) {
                    try {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/api/WebApiManagerTest.java

            }
    
            @Override
            public PrintWriter getWriter() {
                return writer;
            }
    
            public String getWrittenContent() {
                writer.flush();
                return stringWriter.toString();
            }
    
            // Minimal implementations for other required methods
            @Override
            public void addCookie(jakarta.servlet.http.Cookie cookie) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  7. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

        connection.connect()
        val out = connection.outputStream
        val data = ByteArray(1024 * 1024)
        var i = 0
        while (i < 1024) {
          try {
            out.write(data)
            out.flush()
            if (i == 513) {
              // pause slightly after halfway to make result more predictable
              Thread.sleep(100)
            }
          } catch (e: IOException) {
            break
          }
          i++
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 03 13:16:34 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  8. docs/recipes.md

                    }
                  }
                }
    
                val bufferedSink = forwardingSink.buffer()
                delegate.writeTo(bufferedSink)
                bufferedSink.flush()
              }
            }
    
            fun interface ProgressListener {
              fun update(bytesWritten: Long, contentLength: Long, done: Boolean)
            }
          }
        ```
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 17:01:12 UTC 2025
    - 47.8K bytes
    - Viewed (0)
  9. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

            override fun publish(record: LogRecord) {
              calls
                .getOrPut(record.loggerName) { AtomicInteger(0) }
                .incrementAndGet()
            }
    
            override fun flush() {
            }
    
            override fun close() {
            }
          }.apply {
            level = Level.FINEST
          }
    
        Logger
          .getLogger("")
          .addHandler(testHandler)
        Logger
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 14:12:28 UTC 2025
    - 29K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb2/ServerMessageBlock2.java

        /** SMB2 create/open file command */
        protected static final short SMB2_CREATE = 0x0005;
        /** SMB2 close file command */
        protected static final short SMB2_CLOSE = 0x0006;
        /** SMB2 flush file command */
        protected static final short SMB2_FLUSH = 0x0007;
        /** SMB2 read file command */
        protected static final short SMB2_READ = 0x0008;
        /** SMB2 write file command */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 24K bytes
    - Viewed (0)
Back to top