class CassandraUserMailboxRightsDAO {

    public Flux<Pair<CassandraId, Rfc4314Rights>> listRightsForUser(Username userName) {
        return cassandraAsyncExecutor.execute(
            selectUser.bind()
                .setString(USER_NAME, userName.asString()))
            .flatMapMany(cassandraUtils::convertToFlux)
            .map(Throwing.function(this::toPair));
    }

    @Inject public  CassandraUserMailboxRightsDAO(Session session, CassandraUtils cassandraUtils);

}