code: protected Stream<DTO> streamQuery(DBQuery.Query query) {
          final DBCursor<DTO> cursor = db.find(query);
          return Streams.stream((Iterable<DTO>) cursor).onClose(cursor::close);
      }
docs: Returns an unordered stream of database entries for the given {@link DBQuery.Query}.
  <p>
  The returned stream needs to be closed to free the underlying database resources.
  
  @param query the query to execute
  @return stream of database entries that match the query