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    *      https://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  
18  package org.apache.commons.lang3.function;
19  
20  import static org.apache.commons.lang3.LangAssertions.assertNullPointerException;
21  import static org.junit.jupiter.api.Assertions.assertEquals;
22  import static org.junit.jupiter.api.Assertions.assertNotNull;
23  import static org.junit.jupiter.api.Assertions.assertThrows;
24  
25  import java.io.IOException;
26  import java.util.concurrent.atomic.AtomicLong;
27  
28  import org.apache.commons.lang3.AbstractLangTest;
29  import org.junit.jupiter.api.Test;
30  
31  /**
32   * Tests {@link FailableLongConsumer}.
33   */
34  class FailableLongConsumerTest extends AbstractLangTest {
35  
36      @Test
37      void testAccept_invokesConsumer() throws IOException {
38          final AtomicLong ref = new AtomicLong();
39          final FailableLongConsumer<IOException> consumer = ref::set;
40          consumer.accept(100L);
41          assertEquals(100L, ref.get());
42      }
43  
44      @Test
45      void testAccept_throwsException() {
46          final IOException expected = new IOException("fail");
47          final FailableLongConsumer<IOException> consumer = v -> {
48              throw expected;
49          };
50          final IOException thrown = assertThrows(IOException.class, () -> consumer.accept(1L));
51          assertEquals(expected, thrown);
52      }
53  
54      @Test
55      void testAndThen_bothInvoked() throws IOException {
56          final AtomicLong ref1 = new AtomicLong();
57          final AtomicLong ref2 = new AtomicLong();
58          final FailableLongConsumer<IOException> first = ref1::set;
59          final FailableLongConsumer<IOException> second = ref2::set;
60          first.andThen(second).accept(99L);
61          assertEquals(99L, ref1.get());
62          assertEquals(99L, ref2.get());
63      }
64  
65      @Test
66      void testAndThen_firstThrows_secondNotInvoked() {
67          final IOException expected = new IOException("first");
68          final AtomicLong ref = new AtomicLong(-1L);
69          final FailableLongConsumer<IOException> throwing = v -> {
70              throw expected;
71          };
72          final FailableLongConsumer<IOException> second = ref::set;
73          final IOException thrown = assertThrows(IOException.class, () -> throwing.andThen(second).accept(1L));
74          assertEquals(expected, thrown);
75          assertEquals(-1L, ref.get());
76      }
77  
78      @Test
79      void testAndThen_nullAfter_throwsNullPointerException() throws Throwable {
80          final FailableLongConsumer<IOException> consumer = v -> {
81          };
82          assertNullPointerException(() -> consumer.andThen(null));
83      }
84  
85      @Test
86      void testNop_acceptDoesNothing() throws Throwable {
87          FailableLongConsumer.nop().accept(1L);
88      }
89  
90      @Test
91      void testNop_returnsNonNull() {
92          assertNotNull(FailableLongConsumer.nop());
93      }
94  }