@Test
public void shutdownInput() throws IOException {

    NPipeSocketImpl impl = new NPipeSocketImpl();
    connect(impl);
    impl.shutdownInput();
    PipeChannelInputStream inputStream = (PipeChannelInputStream) impl.getInputStream();
    assertThat(inputStream.isShutdown()).isFalse();
    impl.shutdownInput();
    assertThat(inputStream.isShutdown()).isTrue();
}