@Test public void when_Write_Throws_Exception_Expect_Fail_To_Read_Value() { expectedException.expect(RuntimeException.class); expectedException.expectMessage("Unable to properly read from stream"); underTest = new StreamCopier<>(outputStream -> { throw new RuntimeException("Test witting failure"); }, this::readString); underTest.read(1000); }
public T read() { return read(60000); }
StreamCopier extends ComponentSupport { public T read() { return read(60000); } }
StreamCopier extends ComponentSupport { public T read() { return read(60000); } StreamCopier(final Consumer<OutputStream> write, final Function<InputStream, T> read);  StreamCopier(final Consumer<OutputStream> write,
                      final Function<InputStream, T> read,
                      final ExecutorService service); }
StreamCopier extends ComponentSupport { public T read() { return read(60000); } StreamCopier(final Consumer<OutputStream> write, final Function<InputStream, T> read);  StreamCopier(final Consumer<OutputStream> write,
                      final Function<InputStream, T> read,
                      final ExecutorService service); T read(); T read(final long timeoutMilliseconds); StreamCopier<T> afterReadLeaveStreamsOpen(); }
StreamCopier extends ComponentSupport { public T read() { return read(60000); } StreamCopier(final Consumer<OutputStream> write, final Function<InputStream, T> read);  StreamCopier(final Consumer<OutputStream> write,
                      final Function<InputStream, T> read,
                      final ExecutorService service); T read(); T read(final long timeoutMilliseconds); StreamCopier<T> afterReadLeaveStreamsOpen();  }