@Test
public void testCollect() throws IOException {

  this.handler = new NativeCollectorOnlyHandler(taskContext, nativeHandler, pusher, combiner);
  handler.collect(new BytesWritable(), new BytesWritable(), 100);
  handler.close();
  handler.close();
  Mockito.verify(pusher, Mockito.times(1)).collect(any(BytesWritable.class),
      any(BytesWritable.class), anyInt());
  Mockito.verify(pusher, Mockito.times(1)).close();
  Mockito.verify(combiner, Mockito.times(1)).close();
  Mockito.verify(nativeHandler, Mockito.times(1)).close();
}