Возврат ArrayList объекта в rxAndroid

Question

Я хочу периодически запускать метод таким образом, чтобы он возвращал ArrayList пользовательского объекта. Вот мой фрагмент кода,

subscribe = Observable.interval(5, TimeUnit.SECONDS) 
      .map(new Func1<Long, ArrayList<Item>>() { 

       @Override 
       public ArrayList<Item> call(Long aLong) { 
        return new ArrayList<Item>(aLong.intValue()); 
       } 
      }); 

Однако это дает ошибку

map(rx.functions.Func1<? super T, ? extends R>) в Наблюдаемые не может быть применен к (anonymous rx.functions.Func1<java.lang.Long, java.util.ArrayList<com.example.Item>>)

Это прекрасно работает, когда возвращаемое значение является ArrayList<String>. Я не понимаю, в чем проблема. Не разрешены ли пользовательские объекты?

Answer 1

Вы не получаете подписку на карту, вы получаете ее после подписки. Вот пример кода для его демонстрации.

Observable<ArrayList<Item>> observable = Observable.interval(5, TimeUnit.SECONDS) 
      .map(new Func1<Long, ArrayList<Item>>() { 

       @Override 
       public ArrayList<Item> call(Long aLong) { 
        return new ArrayList<Item>(aLong.intValue()); 
       } 
      }); 
    Subscription subscription = observable.subscribe(new Action1<ArrayList<Item>>() { 
     @Override 
     public void call(ArrayList<Item> items) { 
      //Do something with list items here 
     } 
    });