### Question:
StoreStreamingProcess { public void fail( ChannelHandlerContext ctx, StoreCopyFinishedResponse.Status failureCode ) { protocol.end( ctx, failureCode ); } StoreStreamingProcess( StoreFileStreamingProtocol protocol, Supplier<CheckPointer> checkPointerSupplier, StoreCopyCheckPointMutex mutex,
            StoreResourceStreamFactory resourceStreamFactory ); void fail( ChannelHandlerContext ctx, StoreCopyFinishedResponse.Status failureCode );  }### Answer:
@Test public void shouldSignalFailure() { StoreStreamingProcess process = new StoreStreamingProcess( protocol, checkPointerSupplier, mutex, resourceStream ); process.fail( ctx, E_STORE_ID_MISMATCH ); verify( protocol ).end( ctx, E_STORE_ID_MISMATCH ); }