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

Mockito.verify(mBlockStoreContext, Mockito.timeout(1)).acquireWorkerClient();
Mockito.verify(mBlockStoreContext, Mockito.timeout(1)).releaseWorkerClient(mWorkerClient);</BUG>
}

mTestStream.close();
for (long streamIndex = 0; streamIndex < 2; streamIndex ++) {
Assert.assertFalse(mTachyonOutStreamMap.get(streamIndex).isCanceled());
Assert.assertTrue(mTachyonOutStreamMap.get(streamIndex).isClosed());
}
Mockito.verify(mFileSystemMasterClient, Mockito.times(1)).completeFile(Mockito.eq(FILE_ID),
Mockito.any(CompleteFileOptions.class));
}
