Examples of java.io.FileInputStream.available()

java.io.FileInputStream.available()
Returns an estimate of the number of remaining bytes that can be read (or skipped over) from this input stream without blocking by the next invocation of a method for this input stream. The next invocation might be the same thread or another thread. A single read or skip of this many bytes will not block, but may read or skip fewer bytes.
In some cases, a non-blocking read (or skip) may appear to be blocked when it is merely slow, for example when reading large files over slow networks. @return an estimate of the number of remaining bytes that can be read(or skipped over) from this input stream without blocking. @exception IOException if this file input stream has been closed by calling{@code close} or an I/O error occurs.

                    FileInputStream fis;
                    try {
                        for (File f : fPath.getFiles()) {
                            path.append(f.getPath()).append("*");
                            fis = new FileInputStream(f.getPath());
                            total += fis.available();
                        }
                    } catch (IOException ex) {
                        ex.printStackTrace();
                    }

View Full Code Here

      HCatRecord rec = new DefaultHCatRecord();
      rec.readFields(inpStream);
      Assert.assertTrue(HCatDataCheckUtil.recordsEqual(recs[i], rec));
    }


    Assert.assertEquals(fInStream.available(), 0);
    fInStream.close();


  }


  public void testCompareTo() {

View Full Code Here

    {
        FileInputStream fin = new FileInputStream( m_testFile );
        try {
            String out = IOUtils.toString( fin );
            assertNotNull( out );
            assertEquals( "Not all bytes were read", 0, fin.available() );
            assertEquals( "Wrong output size", FILE_SIZE, out.length() );
        } finally {
            fin.close();
        }
    }

View Full Code Here

    {
        FileInputStream fin = new FileInputStream( m_testFile );
        try {
            byte[] out = IOUtils.toByteArray( fin );
            assertNotNull( out );
            assertEquals( "Not all bytes were read", 0, fin.available());
            assertEquals( "Wrong output size", FILE_SIZE, out.length );
            assertEqualContent( out, m_testFile );
        } finally {
            fin.close();
        }

View Full Code Here

        throws Exception {
        FileInputStream fin = new FileInputStream( m_testFile );
        try {
            byte[] out = IOUtils.toByteArray( fin, m_testFile.length());
            assertNotNull( out );
            assertTrue( "Not all bytes were read", fin.available() == 0 );
            assertTrue( "Wrong output size: out.length=" + out.length +
                        "!=" + FILE_SIZE, out.length == FILE_SIZE );
            assertEqualContent( out, m_testFile );
        } finally {
            fin.close();

View Full Code Here

        FileInputStream fin = new FileInputStream(m_testFile);
        try {
            InputStream in = IOUtils.toBufferedInputStream(fin);
            byte[] out = IOUtils.toByteArray(in);
            assertNotNull(out);
            assertEquals("Not all bytes were read", 0, fin.available());
            assertEquals("Wrong output size", FILE_SIZE, out.length );
            assertEqualContent(out, m_testFile);
        } finally {
            fin.close();
        }

View Full Code Here

    {
        FileInputStream fin = new FileInputStream( m_testFile );
        try {
            char[] out = IOUtils.toCharArray( fin );
            assertNotNull( out );
            assertEquals( "Not all chars were read", 0, fin.available());
            assertEquals( "Wrong output size", FILE_SIZE, out.length );
            assertEqualContent( out, m_testFile );
        } finally {
            fin.close();
        }

View Full Code Here

    {
        FileInputStream fin = new FileInputStream( m_testFile );
        try {
            char[] out = IOUtils.toCharArray( fin , "UTF-8" );
            assertNotNull( out );
            assertEquals( "Not all chars were read", 0, fin.available());
            assertEquals( "Wrong output size", FILE_SIZE, out.length);
            assertEqualContent( out, m_testFile );
        } finally {
            fin.close();
        }

View Full Code Here

     */
    private void verifyResultFile(File testFile) {
        try
        {
            FileInputStream fis = new FileInputStream(testFile);
            assertEquals(testBytes.length, fis.available());


            byte[] resultBytes = new byte[testBytes.length];
            assertEquals(testBytes.length, fis.read(resultBytes));


            assertTrue(Arrays.equals(resultBytes, testBytes));

View Full Code Here

            ZipEntry ze = new ZipEntry(entryName);


            try {
                jarOut.putNextEntry(ze);
                FileInputStream file = new FileInputStream(files[i]);
                byte[] fileContents = new byte[file.available()];
                file.read(fileContents);
                jarOut.write(fileContents);
            } catch (Exception e) {
                // Ignore duplicate entry errors 
            }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.