class CassStoreHelper {

    public Observable<ResultSet> execute(Statement statement) {
        return buildResultSetObservable(() -> session.executeAsync(statement));
    }

    public  CassStoreHelper(Session session, Scheduler scheduler);

}