@Test
public void updateDriveFileWithIdentifierErrorIsForwarded() throws Exception {

    final java.io.File file = new java.io.File("/");
    final Exception exception = new Exception("test");
    when(driveDataStreams.updateFile(identifier, file)).thenReturn(Single.error(exception));
    final TestObserver<Identifier> testObserver = driveStreamsManager.updateDriveFile(identifier, file).test();
    testObserver.assertNoValues();
    testObserver.assertNotComplete();
    testObserver.assertError(Exception.class);
    verify(driveErrorStream).onNext(Optional.of(criticalSyncError));
}