@Test public void processor() throws IOException { AtomicInteger count = new AtomicInteger(0); LineOutputStream lpos = new LineOutputStream( (line) -> count.incrementAndGet() ); assertThat(count.get(), is(0)); lpos.write("hello\r\n".getBytes(StandardCharsets.UTF_8)); assertThat(count.get(), is(1)); }
public P processor() { return this.processorRef.get(); }
LineOutputStream extends OutputStream { public P processor() { return this.processorRef.get(); } }
LineOutputStream extends OutputStream { public P processor() { return this.processorRef.get(); } LineOutputStream(P processor);  LineOutputStream(P processor, Charset charset); }
LineOutputStream extends OutputStream { public P processor() { return this.processorRef.get(); } LineOutputStream(P processor);  LineOutputStream(P processor, Charset charset); static LineOutputStream<BufferingProcessor> buffering(); static LineOutputStream<BufferingProcessor> buffering(Charset charset); static LineOutputStream<LastLineProcessor> lastLine(); static LineOutputStream<LastLineProcessor> lastLine(Charset charset); P processor(); void processor(P processor); @Override void close(); @Override void flush(); @Override void write(byte[] buffer, int offset, int length); @Override void write(byte[] b); @Override void write(int b); }
LineOutputStream extends OutputStream { public P processor() { return this.processorRef.get(); } LineOutputStream(P processor);  LineOutputStream(P processor, Charset charset); static LineOutputStream<BufferingProcessor> buffering(); static LineOutputStream<BufferingProcessor> buffering(Charset charset); static LineOutputStream<LastLineProcessor> lastLine(); static LineOutputStream<LastLineProcessor> lastLine(Charset charset); P processor(); void processor(P processor); @Override void close(); @Override void flush(); @Override void write(byte[] buffer, int offset, int length); @Override void write(byte[] b); @Override void write(int b);  }