This is an automated email from the ASF dual-hosted git repository.
ggregory pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/commons-io.git
The following commit(s) were added to refs/heads/master by this push:
new f7bd5f99 Add missing test
f7bd5f99 is described below
commit f7bd5f9915955d26f35eaa06dc2762371b74020c
Author: Gary Gregory <[email protected]>
AuthorDate: Tue Dec 26 11:07:51 2023 -0500
Add missing test
---
.../commons/io/input/ProxyInputStreamTest.java | 144 +++++++++++++++++++++
1 file changed, 144 insertions(+)
diff --git
a/src/test/java/org/apache/commons/io/input/ProxyInputStreamTest.java
b/src/test/java/org/apache/commons/io/input/ProxyInputStreamTest.java
new file mode 100644
index 00000000..9fd65b32
--- /dev/null
+++ b/src/test/java/org/apache/commons/io/input/ProxyInputStreamTest.java
@@ -0,0 +1,144 @@
+/*
+ * 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 static org.junit.jupiter.api.Assertions.assertArrayEquals;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Arrays;
+
+import org.junit.jupiter.api.Test;
+
+/**
+ * Tests {@link ProxyInputStream}.
+ */
+public class ProxyInputStreamTest {
+
+ private static final class ProxyInputStreamFixture extends
ProxyInputStream {
+
+ public ProxyInputStreamFixture(final InputStream proxy) {
+ super(proxy);
+ }
+
+ }
+
+ @Test
+ public void testRead() throws IOException {
+ try (CharSequenceInputStream proxy =
CharSequenceInputStream.builder().setCharSequence("abc").get();
+ ProxyInputStream inputStream = new
ProxyInputStreamFixture(proxy)) {
+ int found = inputStream.read();
+ assertEquals('a', found);
+ found = inputStream.read();
+ assertEquals('b', found);
+ found = inputStream.read();
+ assertEquals('c', found);
+ found = inputStream.read();
+ assertEquals(-1, found);
+ }
+ }
+
+ @Test
+ public void testReadArrayAtMiddleFully() throws IOException {
+ try (CharSequenceInputStream proxy =
CharSequenceInputStream.builder().setCharSequence("abc").get();
+ ProxyInputStream inputStream = new
ProxyInputStreamFixture(proxy)) {
+ final byte[] dest = new byte[5];
+ int found = inputStream.read(dest, 2, 3);
+ assertEquals(3, found);
+ assertArrayEquals(new byte[] { 0, 0, 'a', 'b', 'c' }, dest);
+ found = inputStream.read(dest, 2, 3);
+ assertEquals(-1, found);
+ }
+ }
+
+ @Test
+ public void testReadArrayAtStartFully() throws IOException {
+ try (CharSequenceInputStream proxy =
CharSequenceInputStream.builder().setCharSequence("abc").get();
+ ProxyInputStream inputStream = new
ProxyInputStreamFixture(proxy)) {
+ final byte[] dest = new byte[5];
+ int found = inputStream.read(dest, 0, 5);
+ assertEquals(3, found);
+ assertArrayEquals(new byte[] { 'a', 'b', 'c', 0, 0 }, dest);
+ found = inputStream.read(dest, 0, 5);
+ assertEquals(-1, found);
+ }
+ }
+
+ @Test
+ public void testReadArrayAtStartPartial() throws IOException {
+ try (CharSequenceInputStream proxy =
CharSequenceInputStream.builder().setCharSequence("abc").get();
+ ProxyInputStream inputStream = new
ProxyInputStreamFixture(proxy)) {
+ final byte[] dest = new byte[5];
+ int found = inputStream.read(dest, 0, 2);
+ assertEquals(2, found);
+ assertArrayEquals(new byte[] { 'a', 'b', 0, 0, 0 }, dest);
+ Arrays.fill(dest, (byte) 0);
+ found = inputStream.read(dest, 0, 2);
+ assertEquals(1, found);
+ assertArrayEquals(new byte[] { 'c', 0, 0, 0, 0 }, dest);
+ found = inputStream.read(dest, 0, 2);
+ assertEquals(-1, found);
+ }
+ }
+
+ @Test
+ public void testReadArrayFully() throws IOException {
+ try (CharSequenceInputStream proxy =
CharSequenceInputStream.builder().setCharSequence("abc").get();
+ ProxyInputStream inputStream = new
ProxyInputStreamFixture(proxy)) {
+ final byte[] dest = new byte[5];
+ int found = inputStream.read(dest);
+ assertEquals(3, found);
+ assertArrayEquals(new byte[] { 'a', 'b', 'c', 0, 0 }, dest);
+ found = inputStream.read(dest);
+ assertEquals(-1, found);
+ }
+ }
+
+ @Test
+ public void testReadArrayPartial() throws IOException {
+ try (CharSequenceInputStream proxy =
CharSequenceInputStream.builder().setCharSequence("abc").get();
+ ProxyInputStream inputStream = new
ProxyInputStreamFixture(proxy)) {
+ final byte[] dest = new byte[2];
+ int found = inputStream.read(dest);
+ assertEquals(2, found);
+ assertArrayEquals(new byte[] { 'a', 'b' }, dest);
+ Arrays.fill(dest, (byte) 0);
+ found = inputStream.read(dest);
+ assertEquals(1, found);
+ assertArrayEquals(new byte[] { 'c', 0 }, dest);
+ found = inputStream.read(dest);
+ assertEquals(-1, found);
+ }
+ }
+
+ @Test
+ public void testReadEof() throws Exception {
+ final ByteArrayInputStream proxy = new ByteArrayInputStream(new
byte[2]);
+ try (ProxyInputStream inputStream = new
ProxyInputStreamFixture(proxy)) {
+ int found = inputStream.read();
+ assertEquals(0, found);
+ found = inputStream.read();
+ assertEquals(0, found);
+ found = inputStream.read();
+ assertEquals(-1, found);
+ }
+ }
+
+}
