View Javadoc
1   /*
2    *  Licensed to the Apache Software Foundation (ASF) under one or more
3    *  contributor license agreements.  See the NOTICE file distributed with
4    *  this work for additional information regarding copyright ownership.
5    *  The ASF licenses this file to You under the Apache License, Version 2.0
6    *  (the "License"); you may not use this file except in compliance with
7    *  the License.  You may obtain a copy of the License at
8    *
9    *      http://www.apache.org/licenses/LICENSE-2.0
10   *
11   *  Unless required by applicable law or agreed to in writing, software
12   *  distributed under the License is distributed on an "AS IS" BASIS,
13   *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14   *  See the License for the specific language governing permissions and
15   *  limitations under the License.
16   */
17  package org.apache.commons.compress.utils;
18  
19  import static org.junit.jupiter.api.Assertions.assertEquals;
20  import static org.junit.jupiter.api.Assertions.assertTrue;
21  import static org.junit.jupiter.api.Assertions.fail;
22  
23  import java.io.IOException;
24  import java.io.InputStream;
25  
26  import org.junit.jupiter.api.Test;
27  
28  public class SkipShieldingInputStreamTest {
29  
30      @Test
31      public void testSkipDelegatesToRead() throws IOException {
32          try (InputStream i = new SkipShieldingInputStream(new InputStream() {
33              @Override
34              public int read() {
35                  return -1;
36              }
37  
38              @Override
39              public int read(byte[] b, int off, int len) {
40                  return len;
41              }
42  
43              @Override
44              public long skip(long n) {
45                  fail("skip invoked");
46                  return -1;
47              }
48          })) {
49              assertEquals(100, i.skip(100));
50          }
51      }
52  
53      @Test
54      public void testSkipHasAnUpperBoundOnRead() throws IOException {
55          try (InputStream i = new SkipShieldingInputStream(new InputStream() {
56              @Override
57              public int read() {
58                  return -1;
59              }
60  
61              @Override
62              public int read(byte[] b, int off, int len) {
63                  return len;
64              }
65  
66              @Override
67              public long skip(long n) {
68                  fail("skip invoked");
69                  return -1;
70              }
71          })) {
72              assertTrue(Integer.MAX_VALUE > i.skip(Long.MAX_VALUE));
73          }
74      }
75  
76      @Test
77      public void testSkipSwallowsNegativeArguments() throws IOException {
78          try (InputStream i = new SkipShieldingInputStream(new InputStream() {
79              @Override
80              public int read() {
81                  return -1;
82              }
83  
84              @Override
85              public int read(byte[] b, int off, int len) {
86                  fail("read invoked");
87                  return len;
88              }
89  
90              @Override
91              public long skip(long n) {
92                  fail("skip invoked");
93                  return -1;
94              }
95          })) {
96              assertEquals(0, i.skip(Long.MIN_VALUE));
97          }
98      }
99  
100 }