return Observable.create(new Observable.OnSubscribe<File>() {
@Override
public void call(Subscriber<? super File> subscriber) {
InputStream inputStream = null;
try {
<BUG>inputStream = mContentResolver.openInputStream(uri);

final File destination = mStorageManner.getFile(mTrip.getDirectory(), System.currentTimeMillis() + "." + UriUtils.getExtension(uri, mContentResolver));

if (mStorageManner.copy(inputStream, destination, true)) {
</BUG>
subscriber.onNext(destination);

return Observable.create(new Observable.OnSubscribe<File>() {
@Override
public void call(Subscriber<? super File> subscriber) {
InputStream inputStream = null;
try {
inputStream = contentResolver.openInputStream(uri);
final File destination = storageManner.getFile(trip.getDirectory(), System.currentTimeMillis() + "." + UriUtils.getExtension(uri, contentResolver));
if (storageManner.copy(inputStream, destination, true)) {
subscriber.onNext(destination);
