RxJava从Observable更新数据

我有2个listview的。它包含文本项目。我想从左侧列表中拖动文本项并将其拖放到右侧列表中。 Whith这我没有问题。另外，我有一个Observable，它暗含KalturaVideo对象。下面是代码，我如何得到这个观察到：在右侧列表视图已经加入该功能获取的ID，并且不包括从结果对象，如果对象ID等于从TARGETLIST一些ID：RxJava从Observable更新数据

private Observable<KalturaVideo> getSourceListObservalbe(String kalturaPlaylistId){ 
     Observable<String[]> targetIdList = Observable.just(targetList) 
       .map((List<KalturaVideo> kalturaVideos) -> { 
        if(kalturaVideos == null || kalturaVideos.isEmpty()){ 
         return new String[]{""}; 
        } 
        String[] result = new String[kalturaVideos.size()]; 
        int index = 0; 
        for (KalturaVideo item : kalturaVideos) { 
         result[index] = item.getId(); 
        } 
        return result; 
       }); 
     return Observable.combineLatest(
       targetIdList, 
       KalturaVideoRetriver.getVideoList(BuildPlaylistStep2Activity.this, kalturaPlaylistId), 
       (String[] idListOfTarget, KalturaVideo kalturaVideo) -> { 
        for (String item :idListOfTarget){ 
         if(item.equals(kalturaVideo.getId())){ 
          return null; 
         } 
        } 
        return kalturaVideo; 
       }) 
       .doOnError(throwable -> { 
        int i =0; 
        i++; 
        throwable.printStackTrace(); 
       }) 
       .filter(kalturaVideo -> { 
        return kalturaVideo != null; 
       }); 
    }

下面是一个代码视频retriver：

public class KalturaVideoRetriver { 

    public static final String KALTURA_NEW_PLAYLIST_ID = "NEW_PLAYLIST"; 

    public static Observable<KalturaVideo> getVideoList(Context context, String kalturaPlaylistId){ 
     return Observable.create(new Observable.OnSubscribe<KalturaVideo>() { 
      @Override 
      public void call(Subscriber<? super KalturaVideo> subscriber) { 
       getKalturaPlaylistContentObservable(kalturaPlaylistId, context) 
         .flatMap(new Func1<String[], Observable<?>>() { 
          @Override 
          public Observable<?> call(String[] videoIdList) { 
           return getKalturaVideoListObservable(context, videoIdList) 
             .doOnNext(kalturaVideo -> { 
              subscriber.onNext(kalturaVideo); 
             }) 
             .doOnCompleted(() -> subscriber.onCompleted()); 
          } 
         }) 
         .subscribe(); 
      } 
     }); 
    } 

    private static Observable<KalturaVideo> getKalturaVideoListObservable(Context context, String[] kalturaVideoIdArray){ 
     return Observable.create(new Observable.OnSubscribe<KalturaVideo>() { 
      @Override 
      public void call(Subscriber<? super KalturaVideo> subscriber) { 
       Cursor query; 
       List<KalturaVideo> result = new ArrayList<>(); 
       if(kalturaVideoIdArray == null || kalturaVideoIdArray.length == 0) { 
        query = context.getContentResolver().query(KalturaVideoColumns.CONTENT_URI, null, null, null, null); 
       }else { 
        KalturaVideoSelection where = new KalturaVideoSelection(); 
        where.kalturaIdLike(kalturaVideoIdArray); 
        query = context.getContentResolver().query(
          KalturaVideoColumns.CONTENT_URI, 
          null, 
          where.sel(), 
          where.args(), 
          null); 
       } 
       if(!query.moveToFirst()){ 
        query.close(); 
        subscriber.onCompleted(); 
       } 
       KalturaVideoCursor cursor = new KalturaVideoCursor(query); 
       do{ 
        KalturaVideo video = new KalturaVideo(); 
        video.setId(cursor.getKalturaId()); 
        video.setName(cursor.getName()); 
        video.setDescription(cursor.getDescription()); 
        video.setCategories(cursor.getCategories()); 
        video.setCategoriesIds(cursor.getCategoriesIds()); 
        video.setDownloadUrl(cursor.getDownloadUrl()); 
        video.setThumbnailUrl(cursor.getThumbnailUrl()); 
        video.setDataUrl(cursor.getDataUrl()); 
        video.setDuration(cursor.getDuration()); 
        subscriber.onNext(video); 
       }while (cursor.moveToNext()); 
       query.close(); 
       subscriber.onCompleted(); 
      } 
     }); 
    } 

    private static Observable<String[]> getKalturaPlaylistContentObservable(String kalturaPlaylistId, Context context){ 
     return Observable.create(new Observable.OnSubscribe<String[]>() { 
      @Override 
      public void call(Subscriber<? super String[]> subscriber) { 
       if(kalturaPlaylistId.equals(KALTURA_NEW_PLAYLIST_ID)){ 
        subscriber.onNext(new String[]{}); 
        subscriber.onCompleted(); 
        return; 
       } 
       KalturaPlaylistContentSelection where = new KalturaPlaylistContentSelection(); 
       where.playlistId(kalturaPlaylistId); 
       Cursor query = context.getContentResolver().query(
         KalturaPlaylistContentColumns.CONTENT_URI, 
         null, 
         where.sel(), 
         where.args(), 
         null 
       ); 
       if(!query.moveToFirst()){ 
        subscriber.onNext(new String[]{}); 
        query.close(); 
        subscriber.onCompleted(); 
        return; 
       } 
       KalturaPlaylistContentCursor cursor = new KalturaPlaylistContentCursor(query); 
       String[] result = new String[query.getCount()]; 
       int index = 0; 
       do{ 
        result[index] = cursor.getKalturaVideoId(); 
        index++; 
       }while (query.moveToNext()); 
       query.close(); 
       subscriber.onNext(result); 
       subscriber.onCompleted(); 
      } 
     }); 

    } 

}

首先，retriver，我通过播放列表ID获取视频ID的。如果PlaylistId为空 - 我获取所有视频ID，存储在我的数据库中。在此之后，我通过ID从db获取所有视频，这是我在上一步获得的。

这里是功能，这有助于我获得的所有视频，并显示它：

private Observable<KalturaVideo> fillLists(){ 
     return getSourceListObservalbe(KalturaVideoRetriver.KALTURA_NEW_PLAYLIST_ID) 
       .subscribeOn(Schedulers.io()) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .doOnError(throwable -> { 
        Log.e("TAG", throwable.getCause().toString()); 
       }) 
       .doOnNext(kalturaVideo -> { 
        sourceList.add(kalturaVideo); 
       }) 
       .doOnCompleted(() -> { 
        viewHolder.sourceListView.setAdapter(new BuildPlaylistContentAdapter(
          BuildPlaylistStep2Activity.this, 
          -1, 
          sourceList)); 
        viewHolder.sourceListView.setOnItemLongClickListener(new AdapterView.OnItemLongClickListener() { 
         @Override 
         public boolean onItemLongClick(AdapterView<?> parent, View view, int position, long id) { 
          KalturaVideo video = (KalturaVideo) view.getTag(); 
          ClipData data = ClipData.newPlainText("kalturaVideoId", video.getId()); 
          View.DragShadowBuilder shadowBuilder = new View.DragShadowBuilder(view); 
          view.startDrag(data, shadowBuilder, view, 0); 
          view.setVisibility(View.INVISIBLE); 
          return false; 
         } 
        }); 
        viewHolder.targetListView.setAdapter(new BuildPlaylistContentAdapter(
          BuildPlaylistStep2Activity.this, 
          -1, 
          targetList 
        )); 
       }); 
    }

这里是我如何sibscribe它：

subscription = fillLists().subscribe();

这里是，如何我试图更新2列表拖放后：

targetList.add(video); 
sourceList.clear(); 
fillLists().subscribe();

其中视频 - 是与视图相关的视频，它被删除到新的lis吨。

因此，当我第一次将视图放入另一个列表时，它工作正常。但是，当我把第二次，我在doOnError方法来获取此堆栈跟踪：

04-20 18：46：02.072 8015-8083/com.mediamanagment.app W/System.err的：的Java。 lang.NullPointerException 04-20 18：46：02.072
8015-8083/com.mediamanagment.app W/System.err：at com.mediamanagment.app.activity.BuildPlaylistStep2Activity.lambda $ getSourceListObservalbe $ 3（BuildPlaylistStep2Activity.java:106 ） 04-20 18：46：02.072 8015-8083/com.mediamanagment.app W/System.err： at com.mediamanagment.app.activity.BuildPlaylistStep2Activity.access $ lambda $ 1（BuildPlaylistStep2Ac tivity.java） 04-20 18：46：02.072 8015-8083/com.mediamanagment.app W/System.err： at com.mediamanagment.app.activity.BuildPlaylistStep2Activity $$ Lambda $ 2.call（Unknown Source ）04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err：at rx.functions.Functions $ 3.call（Functions.java:76） 04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err： at rx.operators.OperatorCombineLatest $ Collector.next（OperatorCombineLatest.java:157） 04-20 18：46：02.080 8015-8083/com.mediamanagment .app W/System.err： at rx.operators.OperatorCombineLatest $ SourceSubscriber.onNext（OperatorCombineLatest.java:218） 04-20 1 8：46：02.080 8015-8083/com.mediamanagment.app W/System.err： at com.mediamanagment.app.retrivers.KalturaVideoRetriver $ 1 $ 1.lambda $ call $ 13（KalturaVideoRetriver.java:36） 04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err： at com.mediamanagment.app.retrivers.KalturaVideoRetriver $ 1 $ 1。访问$ lambda $ 0（KalturaVideoRetriver.java） 04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err： at com.mediamanagment.app.retrivers.KalturaVideoRetriver $ 1 $ 1 $$ Lambda $ 1.call（Unknown Source）04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err：在rx.Observable $ 12.onNext（Observable.java:3682）04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err：at rx.operators.OperatorDoOnEach $ 1.onNext（OperatorDoOnEach.java:61）04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err：at com.mediamanagment.app.retrivers.KalturaVideoRetriver $ 2.call（KalturaVideoRetriver.java:80） 04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.e rr： at com.mediamanagment.app.retrivers.KalturaVideoRetriver $ 2.call（KalturaVideoRetriver.java:47） 04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err： at rx.Observable $ 2.call（Observable.java:153）04-20 18：46：02.080
8015-8083/com.mediamanagment.app W/System.err： rx.Observable $ 2.call（Observable.java ：149）04-20 18：46：02.080
8015-8083/com.mediamanagment.app W/System.err：at rx.Observable $ 2.call（Observable.java:153）04-20 18:46： 02.080
8015-8083/com.mediamanagment.app W/System.err：at rx.Observable $ 2.call（Observable.java:149）04-20 18：46：02.080
8015-8083/com.mediamanagment.app W/System.err：at rx.Observable.unsafeSubscribe（Observable.java:6110）04-20 18：46：02.080 8015-8083/com.mediamanagment.app W /System.err：at rx.operators.OperatorMerge $ 1.onNext（OperatorMerge.java:66）04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err：at rx。 Operator.OperatorMerge $ 1.onNext（OperatorMerge.java:43）04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err：at rx.operators.OperatorMap $ 1.onNext（OperatorMap。 java：54）04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err：at com.mediamanagment.app.retrivers.KalturaVideoRetriver $ 3.call（KalturaVideoRetriver.java:93） 04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err： at com.mediamanagment.app.retrivers.KalturaVideoRetriver $ 3.call（KalturaVideoRetriver.java:89） 04-20 18：46：02.080 8015-8083/com.mediamanagment.app W/System.err： at rx.Observable $ 2.call（Observable.java:153）04-20 18：46：02.080
8015-8083/com .mediamanagment.app W/System.err：at rx.Observable $ 2.call（Observable.java:149）04-20 18：46：02.080
8015-8083/com.mediamanagment.app W/System.err： at rx.Observable $ 2.call（Observable.java:153）04-20 18：46：02.088
8015-8083/com.mediamanagment.app W/System.err：at rx.Observa ble $ 2.call（Observable.java:149）04-20 18：46：02.088
8015-8083/com.mediamanagment.app W/System.err：at rx.Observable.subscribe（Observable.java:6177） 04-20 18：46：02.088
8015-8083/com.mediamanagment.app W/System.err：at rx.Observable.subscribe（Observable.java:5842）04-20 18：46：02.088
8015 -8083/com.mediamanagment.app W/System.err：at com.mediamanagment.app.retrivers.KalturaVideoRetriver $ 1.call（KalturaVideoRetriver.java:41） 04-20 18：46：02.088 8015-8083/com。 mediamanagment.app W/System.err： at com.mediamanagment.app.retrivers.KalturaVideoRetriver $ 1.call（KalturaVideoRetriver.java:27） 04- 20 18：46：02.088 8015-8083/com.mediamanagment。应用程序W/System.err： at rx.Observable.unsafeSubscribe（Observable.java:6110）04-20 18：46：02.095 8015-8083/com.mediamanagment.app W/System.err：at rx.operators （OperatorCombineLatest.java:87） 04-20 18：46：02.095 8015-8083/com.mediamanagment.app W/40） 04-20 18：46：02.095 8015-8083/com.mediamanagment.app W/System.err： at rx.Observable $ 2.call（Observable.java:153）04-20 18：46：02.095
8015-8083/com.mediamanagment.app W/System.err：at rx.Observable $ 2.call（Observable.java:149）04-20 18：46：02.095
8015-8083/com.mediamanagment.app W/System.err：at rx.Observable $ 2.call（Observable.java:153）04-20 18：46：02.095
8015-8083/com.mediamanagment.app W/System.err： rx.Observable $ 2.call（Observable.java:149）04-20 18：46：02.095
8015-8083/com.mediamanagment.app W/System.err：at rx。 Observable.unsafeSubscribe（Observable.java:6110）04-20 18：46：02.095 8015-8083/com.mediamanagment.app W/System.err：at rx.operators.OperatorSubscribeOn $ 1 $ 1.call（OperatorSubscribeOn.java： 60） 04-20 18：46：02.095 8015-8083/com.mediamanagment.app W/System.err： at rx.schedulers.NewThreadScheduler $ NewThreadWorker $ ScheduledAction。运行（NewThreadScheduler.java:141） 04-20 18：46：02.095 8015-8083/com.mediamanagment.app W/System.err： at java.util.concurrent.Executors $ RunnableAdapter.call（Executors.java ：390） 04-20 18：46：02.095 8015-8083/com.mediamanagment.app W/System.err： at java.util.concurrent.FutureTask.run（FutureTask.java:234）04-20 18 ：46：02.095 8015-8083/com.mediamanagment.app W/System.err：at java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.access $ 201（ScheduledThreadPoolExecutor.java:153） 04-20 18：46：02.103 8015 -8083/com.mediamanagment.app W/System.err： at java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.run（ScheduledThreadPoolExecutor.java:267） 04-20 18：46：02.103 8015-8083/com.mediamanagment.app W/System.err： at java.util.concurrent.ThreadPoolExecutor.runWorker（ThreadPoolExecutor.java:1080） 04-20 18:46 ：02.103 8015-8083/com.mediamanagment.app W/System.err： at java.util.concurrent.ThreadPoolExecutor $ Worker.run（ThreadPoolExecutor.java:573） 04-20 18：46：02.103 8015-8083 /com.mediamanagment.app W/System.err的：在java.lang.Thread.run（Thread.java:856）

并没有什么视频返回

来源

2015-04-20 Alexander

你已经摹加时赛在此代码

Log.e("TAG", throwable.getCause().toString());

我认为你的异常没有原因的NullPointerException异常，所以toString调用抛出NPE（空指针异常）

与

Log.e("TAG", throwable.getCause());

替换代码它应该解决这个问题

但是你的代码非常复杂，有些部分可以被写en以不同的方式。其他一些越野车。

例如：

错误

.doOnError(throwable -> { 
    int i =0; 
    i++; 
    throwable.printStackTrace(); 
})

i将总是等于0（或1 i++之后）。这是自愿的吗？

错误代码

public static Observable<KalturaVideo> getVideoList(Context context, String kalturaPlaylistId){ 
    return Observable.create(new Observable.OnSubscribe<KalturaVideo>()  { 
     @Override 
     public void call(Subscriber<? super KalturaVideo> subscriber) { 
      getKalturaPlaylistContentObservable(kalturaPlaylistId, context) 
        .flatMap(new Func1<String[], Observable<?>>() { 
         @Override 
         public Observable<?> call(String[] videoIdList) { 
          return getKalturaVideoListObservable(context, videoIdList) 
            .doOnNext(kalturaVideo -> { 
             subscriber.onNext(kalturaVideo); 
            }) 
            .doOnCompleted(() -> subscriber.onCompleted()); 
         } 
        }) 
        .subscribe(); 
     } 
    }); 
}

不要使用一个可观察的可观察。刚刚改造的第一个

public static Observable<KalturaVideo> getVideoList(Context context, String kalturaPlaylistId){ return getKalturaPlaylistContentObservable(kalturaPlaylistId, context).flatMap((String[] videoIdList) -> getKalturaVideoListObservable(context, videoIdList)); }

复杂的代码

Observable<String[]> targetIdList = Observable.just(targetList) .map((List<KalturaVideo> kalturaVideos) -> { if(kalturaVideos == null || kalturaVideos.isEmpty()){ return new String[]{""}; } String[] result = new String[kalturaVideos.size()]; int index = 0; for (KalturaVideo item : kalturaVideos) { result[index] = item.getId(); } return result; });

您尝试重写代码的Rx可本地已经这样做。

Observable<String[]> targetIdList = Observable.just(targetList) .flatMapIterable(videos -> videos) .map(video -> video.getId()) .toList() .map(l -> l.toArray(new String[]));

来源

2015-04-20 22:24:38 dwursteisen

非常感谢您帮助解决我的问题并查看我的代码。你帮了我很多。 – Alexander

RxJava从Observable更新数据

回答

相关问题