package ru.quickresto.qrcp.mapper;

import java.util.List;
import java.util.concurrent.Callable;

import rx.Observable;

public final class ObservableMapper {

    private ObservableMapper() {
        throw new RuntimeException();
    }

    public static <T> Observable<List<T>> queryAll(Class<T> cls) {
        return queryAll(cls, null, null, null);
    }

    public static <T> Observable<List<T>> queryAll(final Class<T> cls, final String[] fields, final String[] operators, final String[] values) {
        return Observable.fromCallable(new Callable<List<T>>() {
            @Override
            public List<T> call() throws Exception {
                return Mapper.queryAll(cls, fields, operators, values);
            }
        });
    }
}

@@ -273,24 +273,22 @@
 ist%3CT%3E%3E 
-queryAll
+select
 (Class%3CT
@@ -311,24 +311,22 @@
  return 
-queryAll
+select
 (cls, nu
@@ -391,24 +391,22 @@
 ist%3CT%3E%3E 
-queryAll
+select
 (final C
@@ -666,16 +666,14 @@
 per.
-queryAll
+select
 (cls

Update ObservableMapper.java