MapDatabase: minor improvements
This commit is contained in:
parent
fce9791cd6
commit
ecbf719d73
@ -308,13 +308,11 @@ public class MapDatabase implements ITileDataSource {
|
|||||||
processBlocks(sink, queryParameters, subFileParameter, tile.getBoundingBox(), Selector.ALL, new MapReadResult());
|
processBlocks(sink, queryParameters, subFileParameter, tile.getBoundingBox(), Selector.ALL, new MapReadResult());
|
||||||
else
|
else
|
||||||
processBlocks(sink, queryParameters, subFileParameter);
|
processBlocks(sink, queryParameters, subFileParameter);
|
||||||
|
sink.completed(QueryResult.SUCCESS);
|
||||||
} catch (Throwable t) {
|
} catch (Throwable t) {
|
||||||
log.error(t.getMessage(), t);
|
log.error(t.getMessage(), t);
|
||||||
sink.completed(QueryResult.FAILED);
|
sink.completed(QueryResult.FAILED);
|
||||||
return;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
sink.completed(QueryResult.SUCCESS);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@ -74,12 +74,11 @@ public class MultiMapDatabase implements ITileDataSource {
|
|||||||
mapDatabase.query(tile, dataSink);
|
mapDatabase.query(tile, dataSink);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
sink.completed(QueryResult.SUCCESS);
|
||||||
} catch (Throwable t) {
|
} catch (Throwable t) {
|
||||||
log.error(t.getMessage(), t);
|
log.error(t.getMessage(), t);
|
||||||
sink.completed(QueryResult.FAILED);
|
sink.completed(QueryResult.FAILED);
|
||||||
return;
|
|
||||||
}
|
}
|
||||||
sink.completed(QueryResult.SUCCESS);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
Loading…
x
Reference in New Issue
Block a user