@Test
public void testComplete() throws IOException {

  ByteArrayOutputStream baos = new ByteArrayOutputStream();
  ThruStagingHandler handler = new ThruStagingHandler( baos, session );
  handler.getStagingOutputStream().write( TEST.getBytes() );
  handler.complete();
  // trim string from tail 00 bytes...
  assertEquals( "Write output only after complete", TEST, baos.toString().trim() );
}