Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for BufferedInputStream (0.15 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java

     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.crawler.client.fs;
    
    import java.io.BufferedInputStream;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.InputStream;
    import java.io.UnsupportedEncodingException;
    import java.net.URI;
    import java.net.URISyntaxException;
    import java.net.URLEncoder;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  2. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb/SmbClient.java

            }
        }
    
        private void copy(final SmbFile src, final File dest) {
            if (dest.exists() && !dest.canWrite()) {
                return;
            }
            try (BufferedInputStream in = new BufferedInputStream(new SmbFileInputStream(src));
                    BufferedOutputStream out = new BufferedOutputStream(new FileOutputStream(dest))) {
                final byte[] buf = new byte[1024];
                int length;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu May 23 01:54:36 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  3. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/PluginDescriptorBuilder.java

            try (BufferedInputStream bis = new BufferedInputStream(inputSupplier.open(), BUFFER_SIZE)) {
                bis.mark(BUFFER_SIZE);
                XMLStreamReader xsr = XMLInputFactory.newFactory().createXMLStreamReader(bis);
                xsr.nextTag();
                String nsUri = xsr.getNamespaceURI();
                try (BufferedInputStream bis2 = reset(inputSupplier, bis)) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/SitemapsHelper.java

        public boolean isValid(final InputStream in) {
            return isValid(in, true);
        }
    
        protected boolean isValid(final InputStream in, final boolean recursive) {
            final BufferedInputStream bis = new BufferedInputStream(in);
            bis.mark(preloadSize);
    
            final byte[] bytes = new byte[preloadSize];
            try {
                if (bis.read(bytes) == -1) {
                    return false;
                }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:40:57 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/transformer/impl/HtmlTransformer.java

                return false;
            }
            return true;
        }
    
        protected String loadCharset(final InputStream inputStream) {
            BufferedInputStream bis = null;
            String encoding = null;
            try {
                bis = new BufferedInputStream(inputStream);
                final byte[] buffer = new byte[preloadSizeForCharset];
                final int size = bis.read(buffer);
                if (size != -1) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Oct 24 12:16:00 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/smb1/SmbClient.java

            }
        }
    
        private void copy(final SmbFile src, final File dest) {
            if (dest.exists() && !dest.canWrite()) {
                return;
            }
            try (BufferedInputStream in = new BufferedInputStream(new SmbFileInputStream(src));
                    BufferedOutputStream out = new BufferedOutputStream(new FileOutputStream(dest))) {
                final byte[] buf = new byte[1024];
                int length;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/io/ByteSource.java

       * @since 15.0 (in 14.0 with return type {@link BufferedInputStream})
       */
      public InputStream openBufferedStream() throws IOException {
        InputStream in = openStream();
        return (in instanceof BufferedInputStream)
            ? (BufferedInputStream) in
            : new BufferedInputStream(in);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/curl/CurlRequest.java

                    }
                });
            }
    
            private void writeContent(final Supplier<InputStream> handler) {
                try (BufferedInputStream bis = new BufferedInputStream(handler.get());
                        ContentOutputStream dfos = new ContentOutputStream(threshold, Curl.tmpDir)) {
                    final byte[] bytes = new byte[4096];
    Registered: Thu Oct 31 02:32:13 UTC 2024
    - Last Modified: Sun Feb 12 12:21:25 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/crawler/transformer/FessXpathTransformer.java

        }
    
        @Override
        protected void storeData(final ResponseData responseData, final ResultData resultData) {
            final DOMParser parser = getDomParser();
            try (final BufferedInputStream bis = new BufferedInputStream(responseData.getResponseBody())) {
                final byte[] bomBytes = new byte[UTF8_BOM_SIZE];
                bis.mark(UTF8_BOM_SIZE);
                final int size = bis.read(bomBytes);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Oct 24 13:01:38 UTC 2024
    - 42.9K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java

     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.crawler.client.storage;
    
    import java.io.BufferedInputStream;
    import java.io.File;
    import java.io.InputStream;
    import java.util.Date;
    import java.util.HashSet;
    import java.util.Set;
    import java.util.concurrent.atomic.AtomicBoolean;
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 13.9K bytes
    - Viewed (0)
Back to top