|
Commons IO example source code file (AutoCloseInputStreamTest.java)
The Commons IO AutoCloseInputStreamTest.java source code/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.commons.io.input; import java.io.ByteArrayInputStream; import java.io.IOException; import java.io.InputStream; import junit.framework.TestCase; /** * JUnit Test Case for {@link AutoCloseInputStream}. */ public class AutoCloseInputStreamTest extends TestCase { private byte[] data; private InputStream stream; private boolean closed; @Override protected void setUp() { data = new byte[] { 'x', 'y', 'z' }; stream = new AutoCloseInputStream(new ByteArrayInputStream(data) { @Override public void close() { closed = true; } }); closed = false; } /** * Test the <code>close() method. */ public void testClose() throws IOException { stream.close(); assertTrue("closed", closed); assertEquals("read()", -1, stream.read()); } /** * Test the <code>read() method. */ public void testRead() throws IOException { for (int i = 0; i < data.length; i++) { assertEquals("read()", data[i], stream.read()); assertFalse("closed", closed); } assertEquals("read()", -1, stream.read()); assertTrue("closed", closed); } /** * Test the <code>read(b) method. */ public void testReadBuffer() throws IOException { byte[] b = new byte[data.length * 2]; int total = 0; for (int n = 0; n != -1; n = stream.read(b)) { assertFalse("closed", closed); for (int i = 0; i < n; i++) { assertEquals("read(b)", data[total + i], b[i]); } total += n; } assertEquals("read(b)", data.length, total); assertTrue("closed", closed); assertEquals("read(b)", -1, stream.read(b)); } /** * Test the <code>read(b, off, len) method. */ public void testReadBufferOffsetLength() throws IOException { byte[] b = new byte[data.length * 2]; int total = 0; for (int n = 0; n != -1; n = stream.read(b, total, b.length - total)) { assertFalse("closed", closed); total += n; } assertEquals("read(b, off, len)", data.length, total); for (int i = 0; i < data.length; i++) { assertEquals("read(b, off, len)", data[i], b[i]); } assertTrue("closed", closed); assertEquals("read(b, off, len)", -1, stream.read(b, 0, b.length)); } } Other Commons IO examples (source code examples)Here is a short list of links related to this Commons IO AutoCloseInputStreamTest.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2024 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.