@Test
void onClose() {

    final AtomicInteger cnt = new AtomicInteger();
    final Stream<String> newStream = instance.onClose(cnt::incrementAndGet);
    newStream.close();
    assertEquals(1, cnt.get());
}