#Java - Code Snippets for '#OutputStream'

#Java - Code Snippets for '#OutputStream' - 19 code snippet(s) found

Sample 1. Code Sample / Example / Snippet of java.util.zip.DeflaterOutputStream

    private byte[] deflate(byte[] b) throws IOException {

        ByteArrayOutputStream baos = new ByteArrayOutputStream();

        DeflaterOutputStream dos = new DeflaterOutputStream(baos);

        dos.write(b);

        dos.close();

        return baos.toByteArray();

    }

_{Like Feedback java.util.zip.DeflaterOutputStream}

Sample 2. Code Sample / Example / Snippet of java.util.jar.JarOutputStream

    private File createBundle(String symbolicName, String version) throws IOException {

        File tmpFile = File.createTempFile("tmpbundle-", "jar");

        tmpFile.deleteOnExit();

        Manifest manifest = new Manifest();

        manifest.getMainAttributes().put(Attributes.Name.MANIFEST_VERSION, "1.0");

        if (symbolicName != null) {

            manifest.getMainAttributes().putValue(Constants.BUNDLE_SYMBOLICNAME, symbolicName);

        }

        if (version != null) {

            manifest.getMainAttributes().putValue(Constants.BUNDLE_VERSION, version);

        }

        JarOutputStream target = new JarOutputStream(new FileOutputStream(tmpFile), manifest);

        target.close();

        return tmpFile;

    }

_{Like Feedback java.util.jar.JarOutputStream}

Sample 3. Code Sample / Example / Snippet of java.io.FileOutputStream

    public static void copy(File input, File output) throws IOException {

        FileInputStream fis = new FileInputStream(input);

        FileOutputStream fos = new FileOutputStream(output);



        try {

            FileChannel ic = fis.getChannel();

            FileChannel oc = fos.getChannel();

            try {

                oc.transferFrom(ic, 0, ic.size());

            }

            finally {

                oc.close();

                ic.close();

            }

        }

        finally {

            fis.close();

            fos.close();

        }

    }

_{Like Feedback java.io.FileOutputStream}

Sample 4. Write to a file using File, FileOutputStream and ObjectOutputStream

class BuggyBread1{

   public static void main(String[] args){

      try {

         BuggyBread1 buggybread1 = new BuggyBread1();

         ObjectOutputStream objectOutputStream = new ObjectOutputStream(new FileOutputStream(new File("newFile.txt")));

         objectOutputStream.writeObject(buggybread1);

      } catch (Exception e) {

         e.printStackTrace();

      }

   }

}

_{Like Feedback File FileOutputStream ObjectOutputStream file handling}

Sample 5. Usage of ByteArrayOutputStream

ByteArrayOutputStream baos = new ByteArrayOutputStream();

try {

ObjectOutputStream oos = new ObjectOutputStream(baos);

oos.writeObject(validator);

oos.flush();

oos.close();

} catch (Exception e) {

}

_{Like Feedback java.io.ByteArrayOutputStream java.io ObjectOutputStream}

Sample 6. Code Sample / Example / Snippet of org.apache.storm.blobstore.AtomicOutputStream

    private static void createBlobWithContent(String blobKey, ClientBlobStore clientBlobStore, File file)

            throws AuthorizationException, KeyAlreadyExistsException, IOException,KeyNotFoundException {

        String stringBlobACL = "o::rwa";

        AccessControl blobACL = BlobStoreAclHandler.parseAccessControl(stringBlobACL);

        List<AccessControl> acls = new LinkedList<AccessControl>();

        acls.add(blobACL); // more ACLs can be added here

        SettableBlobMeta settableBlobMeta = new SettableBlobMeta(acls);

        AtomicOutputStream blobStream = clientBlobStore.createBlob(blobKey,settableBlobMeta);

        blobStream.write(readFile(file).toString().getBytes());

        blobStream.close();

    }

_{Like Feedback org.apache.storm.blobstore.AtomicOutputStream}

Sample 7. Code Sample / Example / Snippet of java.io.ByteArrayOutputStream

  private static Pair<SqlLine.Status, String> run(String... args)

      throws Throwable {

    SqlLine sqlline = new SqlLine();

    ByteArrayOutputStream os = new ByteArrayOutputStream();

    PrintStream sqllineOutputStream = new PrintStream(os);

    sqlline.setOutputStream(sqllineOutputStream);

    sqlline.setErrorStream(sqllineOutputStream);

    SqlLine.Status status = SqlLine.Status.OK;



    Bug.upgrade("[sqlline-35] Make Sqlline.begin public");



    return Pair.of(status, os.toString("UTF8"));

  }

_{Like Feedback java.io.ByteArrayOutputStream}

Sample 8. Code Sample / Example / Snippet of javax.servlet.ServletOutputStream

    protected void doGet(HttpServletRequest request, HttpServletResponse response) {

        ServletOutputStream output = null;

        try {

            output = response.getOutputStream();

            output.println(request.getQueryString());

        }

        catch (IOException e) {

        } finally {

            if (output != null) {

                try {

                    output.close();

                }

                catch (IOException e) {

                }

            }

        }

    }

_{Like Feedback javax.servlet.ServletOutputStream}

Sample 9. Code Sample / Example / Snippet of java.security.DigestOutputStream

    public void setUpTestCase() throws Exception {

        File file = File.createTempFile("test", ".bin", new File("generated"));

        file.deleteOnExit();



        DigestOutputStream dos = null;

        try {

            dos = new DigestOutputStream(new FileOutputStream(file), MessageDigest.getInstance("MD5"));



            for (int i = 0; i < 10000; i++) {

                dos.write(String.valueOf(System.currentTimeMillis()).getBytes());

                dos.write(" Lorum Ipsum Lorum Ipsum Lorum Ipsum Lorum Ipsum Lorum Ipsum
".getBytes());

            }

            dos.flush();

        }

        finally {

            if (dos != null) {

                dos.close();

            }

        }



        m_testContentURL = file.toURI().toURL();

        m_contentLength = file.length();

        m_digest = new String(dos.getMessageDigest().digest());

    }

_{Like Feedback java.security.DigestOutputStream}

Sample 10. Code Sample / Example / Snippet of java.io.ByteArrayOutputStream

            public int compare(ResourceImpl r1, ResourceImpl r2) {

                String s1 = getName(r1);

                String s2 = getName(r2);

                return s1.compareTo(s2);

            }

        });



        Tag tag = doIndex(sorted);

        if (repositoryFileName != null) {

            ByteArrayOutputStream out = new ByteArrayOutputStream();

_{Like Feedback java.io.ByteArrayOutputStream}

Sample 11. Code Sample / Example / Snippet of java.io.OutputStream

    public static void generateBundle(ArtifactData data, Map<String, String> additionalHeaders) throws IOException {

        OutputStream bundleStream = null;

        try {

            File dataFile = new File(data.getUrl().toURI());

            OutputStream fileStream = new FileOutputStream(dataFile);

            bundleStream = new JarOutputStream(fileStream, getBundleManifest(data.getSymbolicName(), data.getVersion(), additionalHeaders));

            bundleStream.flush();

        } catch (URISyntaxException e) {

            throw new IOException();

        } finally {

            if (bundleStream != null) {

                bundleStream.close();

            }

        }

    }

_{Like Feedback java.io.OutputStream}

Sample 12. Code Sample / Example / Snippet of org.apache.commons.compress.archivers.ArchiveOutputStream

    protected File createEmptyArchive(final String archivename) throws Exception {

        ArchiveOutputStream out = null;

        OutputStream stream = null;

        archiveList = new ArrayList<String>();

        try {

            archive = File.createTempFile("empty", "." + archivename);

            archive.deleteOnExit();

            stream = new FileOutputStream(archive);

            out = factory.createArchiveOutputStream(archivename, stream);

            out.finish();

        } finally {

            if (out != null) {

                out.close();

            } else if (stream != null) {

                stream.close();

            }

        }

        return archive;

    }

_{Like Feedback org.apache.commons.compress.archivers.ArchiveOutputStream}

Sample 13. Code Sample / Example / Snippet of org.apache.commons.compress.compressors.gzip.GzipCompressorOutputStream

    private void testExtraFlags(final int compressionLevel, final int flag) throws Exception {

        final FileInputStream fis = new FileInputStream(getFile("test3.xml"));

        byte[] content;

        try {

            content = IOUtils.toByteArray(fis);

        } finally {

            fis.close();

        }

        

        final ByteArrayOutputStream bout = new ByteArrayOutputStream();

        

        final GzipParameters parameters = new GzipParameters();

        parameters.setCompressionLevel(compressionLevel);

        final GzipCompressorOutputStream out = new GzipCompressorOutputStream(bout, parameters);

        IOUtils.copy(new ByteArrayInputStream(content), out);

        out.flush();

        out.close();

        

        assertEquals("extra flags (XFL)", flag, bout.toByteArray()[8]);

    }

_{Like Feedback org.apache.commons.compress.compressors.gzip.GzipCompressorOutputStream}

Sample 14. Code Sample / Example / Snippet of org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream

    public void testCompressionMethod() throws Exception {

        final ZipArchiveOutputStream zos =

            new ZipArchiveOutputStream(new ByteArrayOutputStream());

        final ZipArchiveEntry entry = new ZipArchiveEntry("foo");

        assertEquals(-1, entry.getMethod());

        assertFalse(zos.canWriteEntryData(entry));



        entry.setMethod(ZipEntry.STORED);

        assertEquals(ZipEntry.STORED, entry.getMethod());

        assertTrue(zos.canWriteEntryData(entry));



        entry.setMethod(ZipEntry.DEFLATED);

        assertEquals(ZipEntry.DEFLATED, entry.getMethod());

        assertTrue(zos.canWriteEntryData(entry));



        entry.setMethod(6);

        assertEquals(6, entry.getMethod());

        assertFalse(zos.canWriteEntryData(entry));

        zos.close();

    }

_{Like Feedback org.apache.commons.compress.archivers.zip.ZipArchiveOutputStream}

Sample 15. Code Sample / Example / Snippet of org.apache.commons.compress.archivers.tar.TarArchiveOutputStream

    public void shouldUseSpecifiedEncodingWhenReadingGNULongNames()

        throws Exception {

        final ByteArrayOutputStream bos = new ByteArrayOutputStream();

        final String encoding = CharsetNames.UTF_16;

        final String name = "1234567890123456789012345678901234567890123456789"

            + "01234567890123456789012345678901234567890123456789"

            + "01234567890u00e4";

        final TarArchiveOutputStream tos =

            new TarArchiveOutputStream(bos, encoding);

        tos.setLongFileMode(TarArchiveOutputStream.LONGFILE_GNU);

        TarArchiveEntry t = new TarArchiveEntry(name);

        t.setSize(1);

        tos.putArchiveEntry(t);

        tos.write(30);

        tos.closeArchiveEntry();

        tos.close();

        final byte[] data = bos.toByteArray();

        final ByteArrayInputStream bis = new ByteArrayInputStream(data);

        final TarArchiveInputStream tis =

            new TarArchiveInputStream(bis, encoding);

        t = tis.getNextTarEntry();

        assertEquals(name, t.getName());

        tis.close();

    }

_{Like Feedback org.apache.commons.compress.archivers.tar.TarArchiveOutputStream}

Sample 16. Code Sample / Example / Snippet of org.apache.commons.compress.compressors.bzip2.BZip2CompressorOutputStream

    public void readOfLength0ShouldReturn0() throws Exception {

        final byte[] rawData = new byte[1048576];

        for (int i=0; i < rawData.length; ++i) {

            rawData[i] = (byte) Math.floor(Math.random()*256);

        }



        final ByteArrayOutputStream baos = new ByteArrayOutputStream();

        final BZip2CompressorOutputStream bzipOut = new BZip2CompressorOutputStream(baos);

        bzipOut.write(rawData);

        bzipOut.flush();

        bzipOut.close();

        baos.flush();

        baos.close();



        final ByteArrayInputStream bais = new ByteArrayInputStream(baos.toByteArray());

        final BZip2CompressorInputStream bzipIn = new BZip2CompressorInputStream(bais);

        final byte[] buffer = new byte[1024];

        Assert.assertEquals(1024, bzipIn.read(buffer, 0, 1024));

        Assert.assertEquals(0, bzipIn.read(buffer, 1024, 0));

        Assert.assertEquals(1024, bzipIn.read(buffer, 0, 1024));

        bzipIn.close();

    }

_{Like Feedback org.apache.commons.compress.compressors.bzip2.BZip2CompressorOutputStream}

Sample 17. Code Sample / Example / Snippet of org.apache.commons.compress.utils.CountingOutputStream

    public void output() throws Exception {

        final ByteArrayOutputStream bos = new ByteArrayOutputStream();

        final CountingOutputStream o = new CountingOutputStream(bos);

        o.write(1);

        assertEquals(1, o.getBytesWritten());

        o.write(new byte[] { 2, 3 });

        assertEquals(3, o.getBytesWritten());

        o.write(new byte[] { 2, 3, 4, 5, }, 2, 1);

        assertEquals(4, o.getBytesWritten());

        o.count(-1);

        assertEquals(4, o.getBytesWritten());

        o.count(-2);

        assertEquals(2, o.getBytesWritten());

        o.close();

        assertArrayEquals(new byte[] { 1, 2, 3, 4 }, bos.toByteArray());

    }

_{Like Feedback org.apache.commons.compress.utils.CountingOutputStream}

Sample 18. Code Sample / Example / Snippet of org.apache.commons.compress.compressors.deflate.DeflateCompressorOutputStream

    public void canReadASingleByteFlushAndFinish() throws IOException {

        final ByteArrayOutputStream bos = new ByteArrayOutputStream();

        final DeflateCompressorOutputStream cos = new DeflateCompressorOutputStream(bos);

        cos.write(99);

        cos.flush();

        cos.finish();

        Assert.assertTrue(bos.toByteArray().length > 0);

        cos.close();

    }

_{Like Feedback org.apache.commons.compress.compressors.deflate.DeflateCompressorOutputStream}

Sample 19. GunZip file using Apache Commons

   public void testGzipCreation() throws Exception {

     final File input = getFile("test1.xml");

     final File output = new File(dir, "test1.xml.gz");

     final OutputStream out = new FileOutputStream(output);

     try {

      final CompressorOutputStream cos = new CompressorStreamFactory().createCompressorOutputStream("gz", out);

      try {

       IOUtils.copy(new FileInputStream(input), cos);

      } finally {

       cos.close();

      }

     } finally {

      out.close();

     }

    }

_{Like Feedback Zip file using Apache Commons Compress file using Apache Commons GunZip file using Apache Commons Code Sample / Example / Snippet of org.apache.commons.compress.compressors.CompressorOutputStream IOUtils.copy}

Search Java Code Snippets