@Test public void testFlush() throws Exception { DistributedLogManager dlm = mock(DistributedLogManager.class); AppendOnlyStreamWriter writer = mock(AppendOnlyStreamWriter.class); DLOutputStream out = new DLOutputStream(dlm, writer); out.flush(); verify(writer, times(1)).force(eq(false)); }
@Override public void flush() throws IOException { writer.force(false); }
DLOutputStream extends OutputStream { @Override public void flush() throws IOException { writer.force(false); } }
DLOutputStream extends OutputStream { @Override public void flush() throws IOException { writer.force(false); } DLOutputStream(DistributedLogManager dlm,
                        AppendOnlyStreamWriter writer); }
DLOutputStream extends OutputStream { @Override public void flush() throws IOException { writer.force(false); } DLOutputStream(DistributedLogManager dlm,
                        AppendOnlyStreamWriter writer); @Override void write(int b); @Override void write(byte[] b, int off, int len); @Override void write(byte[] b); @Override void flush(); @Override void close(); }
DLOutputStream extends OutputStream { @Override public void flush() throws IOException { writer.force(false); } DLOutputStream(DistributedLogManager dlm,
                        AppendOnlyStreamWriter writer); @Override void write(int b); @Override void write(byte[] b, int off, int len); @Override void write(byte[] b); @Override void flush(); @Override void close();  }