@Test public void when_Write_To_OutputStream_Expect_To_Read_Written_Value_Multiple_Times() { underTest = new StreamCopier<>(this::writeString, this::readString); assertThat(underTest.read(), is(equalTo(DEFAULT_READ_OUTPUT))); assertThat(underTest.read(), is(equalTo(DEFAULT_READ_OUTPUT))); }
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();  }