@Test
public void createDataOutputWrapperCallsReplacesDelegateTarget() {

    // given
    SingleThreadJsonFactory factory = new SingleThreadJsonFactory();
    DataOutput dataOutput1 = mock(DataOutput.class);
    factory._createDataOutputWrapper(dataOutput1);
    assertSame(factory.dataOutputDelegate.getDelegate(), dataOutput1);
    // when
    DataOutput dataOutput2 = mock(DataOutput.class);
    factory._createDataOutputWrapper(dataOutput2);
    // then
    assertSame(factory.dataOutputDelegate.getDelegate(), dataOutput2);
}