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.io.input;
18
19 import static org.junit.jupiter.api.Assertions.assertThrows;
20
21 import java.io.IOException;
22 import java.io.InputStream;
23 import java.nio.file.StandardOpenOption;
24
25 import org.junit.jupiter.api.BeforeEach;
26 import org.junit.jupiter.api.Test;
27
28 /**
29 * Tests functionality of {@link BufferedFileChannelInputStream}.
30 *
31 * This class was ported and adapted from Apache Spark commit 933dc6cb7b3de1d8ccaf73d124d6eb95b947ed19 where it was called
32 * {@code BufferedFileChannelInputStreamSuite}.
33 */
34 public class BufferedFileChannelInputStreamTest extends AbstractInputStreamTest {
35
36 @SuppressWarnings("resource")
37 @Override
38 @BeforeEach
39 public void setUp() throws IOException {
40 super.setUp();
41 // @formatter:off
42 inputStreams = new InputStream[] {
43 new BufferedFileChannelInputStream(inputFile), // default
44 new BufferedFileChannelInputStream(inputFile, 123), // small, unaligned buffer size
45 BufferedFileChannelInputStream.builder().setPath(inputFile).get(), // default
46 BufferedFileChannelInputStream.builder().setPath(inputFile).setBufferSize(123).get(), // small, unaligned buffer size
47 BufferedFileChannelInputStream.builder().setURI(inputFile.toUri()).setBufferSize(1024).get(), // URI and buffer size
48 BufferedFileChannelInputStream.builder().setPath(inputFile).setOpenOptions(StandardOpenOption.READ).get(), // open options
49 };
50 //@formatter:on
51 }
52
53 @Test
54 public void testBuilderGet() {
55 // java.lang.IllegalStateException: origin == null
56 assertThrows(IllegalStateException.class, () -> BufferedFileChannelInputStream.builder().get());
57 }
58
59 }