mTestStream.cancel();
for (long streamIndex = 0; streamIndex < 2; streamIndex ++) {
Assert.assertTrue(mTachyonOutStreamMap.get(streamIndex).isClosed());
Assert.assertTrue(mTachyonOutStreamMap.get(streamIndex).isCanceled());
}
<BUG>Mockito.verify(mWorkerClient, Mockito.times(0)).persistFile(Mockito.anyLong(),
Mockito.anyLong(), Mockito.anyString());
Mockito.verify(mFileSystemMasterClient, Mockito.times(0)).completeFile(FILE_ID);

Mockito.verify(mUnderFileSystem, Mockito.times(1)).delete(Mockito.anyString(),</BUG>
Mockito.eq(false));

mTestStream.cancel();
for (long streamIndex = 0; streamIndex < 2; streamIndex ++) {
Assert.assertTrue(mTachyonOutStreamMap.get(streamIndex).isClosed());
Assert.assertTrue(mTachyonOutStreamMap.get(streamIndex).isCanceled());
}
Mockito.verify(mFileSystemMasterClient, Mockito.times(0)).completeFile(FILE_ID,
CompleteFileOptions.defaults());
Mockito.verify(mUnderFileSystem, Mockito.times(1)).delete(Mockito.anyString(),
