Examples of CountingInputStream

com.amazonaws.util.CountingInputStream
Simple input stream wrapper utility to count the bytes read from a stream.
com.asakusafw.windgate.stream.CountingInputStream
{@link InputStream} with counting bytes to be read. @since 0.2.4
com.emc.vipr.transform.util.CountingInputStream
com.facebook.presto.jdbc.internal.guava.io.CountingInputStream
An {@link InputStream} that counts the number of bytes read. @author Chris Nokleberg @since 1.0
com.fasterxml.storemate.store.util.CountingInputStream
Wrapper for {@link InputStream} that keeps track of number of bytesread and skipped. It can also optionally calculate checksum over read data.
com.google.common.io.CountingInputStream
An {@link InputStream} that counts the number of bytes read. @author Chris Nokleberg @since Guava release 01
de.undercouch.bson4jackson.io.CountingInputStream
Reads from another input stream, but counts the number of bytes read or skipped (i.e. saves the current buffer position). @author Michel Kraemer
net.sf.cram.io.CountingInputStream
org.apache.commons.compress.utils.CountingInputStream
Stream that tracks the number of bytes read. @since Apache Commons Compress 1.3 @NotThreadSafe
org.apache.commons.io.input.CountingInputStream
A decorating input stream that counts the number of bytes that have passed through so far. @author Henri Yandell @author Marcelo Liberato @version $Id: CountingInputStream.java 160202 2005-04-05 17:22:21Z roxspring $
org.apache.james.mailbox.store.streaming.CountingInputStream
{@link InputStream} implementation which just consume the the wrapped {@link InputStream} and countthe lines which are contained within the wrapped stream
org.apache.openejb.server.stream.CountingInputStream
org.apache.tika.io.CountingInputStream
A decorating input stream that counts the number of bytes that have passed through the stream so far.
A typical use case would be during debugging, to ensure that data is being read as expected. @author Marcelo Liberato @since Apache Tika 0.4, copied from Commons IO 1.4
org.terrier.utility.io.CountingInputStream
Sub-Class of Filter Input Stream with the extra method getPos which returns the position in the Stream @author Richard McCreadie and Craig Macdonald
org.tmatesoft.svn.core.internal.util.CountingInputStream
@version 1.1.2 @author TMate Software Ltd.

Examples of org.apache.tika.io.CountingInputStream

        // Automatically detect the MIME type of the document 
        MediaType type = detector.detect(stream, metadata);
        metadata.set(Metadata.CONTENT_TYPE, type.toString());


        // TIKA-216: Zip bomb prevention
        CountingInputStream count = new CountingInputStream(stream);
        SecureContentHandler secure = new SecureContentHandler(handler, count);


        // Parse the document
        try {
            super.parse(count, secure, metadata, context);

View Full Code Here

Examples of org.apache.tika.io.CountingInputStream

    private CountingInputStream stream;


    private SecureContentHandler handler;


    protected void setUp() {
        stream = new CountingInputStream(new NullInputStream(MANY_BYTES));
        handler = new SecureContentHandler(new DefaultHandler(), stream);
    }

View Full Code Here

Examples of org.apache.tika.io.CountingInputStream

        // Automatically detect the MIME type of the document
        MediaType type = detector.detect(stream, metadata);
        metadata.set(Metadata.CONTENT_TYPE, type.toString());


        // TIKA-216: Zip bomb prevention
        CountingInputStream count = new CountingInputStream(stream);
        SecureContentHandler secure = new SecureContentHandler(handler, count);


        // Parse the document
        try {
            super.parse(count, secure, metadata, context);

View Full Code Here

Examples of org.terrier.utility.io.CountingInputStream

    start = offset;
    
    if (codec !=null)
    {
      start = 0;
      inputStream = new CountingInputStream(_input);
      internalInputStream = codec.createInputStream(inputStream);
    } 
    else 
    {
      if (start != 0) //TODO: start is always zero? 
      {
            --start;
            _input.seek(start);
      }
      internalInputStream = inputStream = new CountingInputStream(_input, start);
    }
    Collection rtr = CollectionFactory.loadCollection(
      ApplicationSetup.getProperty("trec.collection.class", "TRECCollection"), 
      new Class[]{InputStream.class}, 
      new Object[]{internalInputStream});

View Full Code Here

Examples of org.terrier.utility.io.CountingInputStream

    readDocumentBlacklist(ApplicationSetup.makeAbsolute(
      ApplicationSetup.getProperty("trec.blacklist.docids", ""), 
    ApplicationSetup.TERRIER_ETC));
    
      
    br = input instanceof CountingInputStream ? (CountingInputStream)input : new CountingInputStream(input);
    documentsInThisFile = 0;
  }

View Full Code Here

Examples of org.terrier.utility.io.CountingInputStream

        {
          //logger.warn("Could not open "+filename+" : Cannot read");
        }
        else
        {  //filename seems ok, open it
          br = new CountingInputStream(Files.openFileStream(filename)); //throws an IOException, throw upwards
          //logger.info("Processing "+filename);
          currentFilename = filename;
          //no need to loop again
          tryFile = false;
          //return success

View Full Code Here

Examples of org.tmatesoft.svn.core.internal.util.CountingInputStream

            }
            return -1;
        }


        if (mySAXParser == null) {
            CountingInputStream stream = null;
            try {
                mySAXParser = getSAXParserFactory().newSAXParser();
                if (myRequest.getContentLength() > 0) {
                    org.xml.sax.XMLReader reader = mySAXParser.getXMLReader();
                    reader.setContentHandler(this);
                    reader.setDTDHandler(this);
                    reader.setErrorHandler(this);
                    reader.setEntityResolver(this);
                    stream = new CountingInputStream(getRequestInputStream());
                    XMLReader xmlReader = new XMLReader(stream);
                    reader.parse(new InputSource(xmlReader));
                }
            } catch (ParserConfigurationException e) {
                if (stream == null || stream.getBytesRead() > 0) {
                    SVNErrorManager.error(SVNErrorMessage.create(SVNErrorCode.RA_DAV_REQUEST_FAILED, e), e, SVNLogType.NETWORK);
                }
            } catch (SAXException e) {
                if (stream == null || stream.getBytesRead() > 0) {
                    SVNErrorManager.error(SVNErrorMessage.create(SVNErrorCode.RA_DAV_REQUEST_FAILED, e), e, SVNLogType.NETWORK);
                }
            } catch (IOException e) {
                if (stream == null || stream.getBytesRead() > 0) {
                    SVNErrorManager.error(SVNErrorMessage.create(SVNErrorCode.RA_DAV_REQUEST_FAILED, e), e, SVNLogType.NETWORK);
                }
            }


            if (stream != null) {
                if (stream.getBytesRead() > 0) {
                    getDAVRequest().init();
                }
                return stream.getBytesRead();
            }
        }
        
        return 0;
    }

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.