Tag: system.reactive

在哪里绘制反应式编程线

在我的项目中,我一直在使用RxJava大约一年。 随着时间的推移,我开始非常喜欢它 – 现在我想也许太多了… 我写的大多数方法现在都有某种forms的Rx,这太棒了! (直到不是)。 我现在注意到有些方法需要大量的工作来组合不同的可观察生产方法。 我感觉到虽然我明白我写的东西,但下一位程序员很难理解我的代码。 在底线之前,让我直接从我在Kotlin的代码给出一个例子(不要太深入): private fun getCachedEntities( getManyFunc: () -> Observable<Timestamped<List>>, getFromNetwork: () -> Observable<ListResult>, getFunc: (String) -> Observable<Timestamped>, insertFunc: (T) -> Unit, updateFunc: (T) -> Unit, deleteFunc: (String) -> Unit) = concat( getManyFunc().filter { isNew(it.timestampMillis) } .map { ListResult(it.value, “”) }, getFromNetwork().doOnNext { syncWithStorage(it.entities, getFunc, insertFunc, updateFunc, deleteFunc) }).first() […]

Android的Kotlin扩展开销

在代码中使用kotlin扩展是个好主意吗? 我非常想念iOS的扩展,但这是在android中使用这些东西的好方法吗? 请参阅http://antonioleiva.com/kotlin-android-extension-functions/ 有没有更好的解决方案呢?

无法使用RxKotlin更改ActionMenuItemView的文本

我试图用Kotlin编写一个Android应用程序。 现在,我想在ActionBar中显示一个计数器。 我为此添加了一个名为show_timer的项目。 每秒钟,它应该数一个: override fun onWindowFocusChanged(hasFocus: Boolean) { val item = findViewById(R.id.show_timer) as ActionMenuItemView PublishSubject.interval(1, java.util.concurrent.TimeUnit.SECONDS, Schedulers.newThread()) .subscribeBy(onNext = {item.text = it.toString()}) super.onWindowFocusChanged(hasFocus) } 但不知何故,这是行不通的。 它将默认文本更新为0,但在此之后它什么都不做。 有人知道为什么这不起作用吗? 先谢谢你, 尼克拉斯

用RX和Kotlin编写网络请求

我正在使用与RXJava和Retrofit进行网络调用的kotlin的Android应用程序。 在启动时,应用程序将对类似REST的后端执行多个网络调用。 该程序看起来非常像Netflix在其示例中使用的程序。 然而,当试图重写它与Kotlin一起工作时,我正在挣扎。 我很难理解Kotlin关闭中的回报如何工作。 非常感谢这里的一些帮助! Netflix的例子: return getUser(userId).flatMap(user -> { Observable<Map<String, Object>> catalog = getPersonalizedCatalog(user) .flatMap(catalogList -> catalogList.videos().<Map<String, Object>> flatMap( video -> { Observable<Bookmark> bookmark = getBookmark(video); Observable<Rating> rating = getRatings(video); Observable<VideoMetadata> metadata = getVideoMetadata(video); return Observable.zip(bookmark, rating, metadata, (b, r, m) -> combineVideoData(video, b, r, m)); })); Observable<Map<String, Object>> social = getSocial(user).map(s -> […]

Android的Kotlin扩展开销

在代码中使用kotlin扩展是个好主意吗? 我非常想念iOS的扩展,但这是在android中使用这些东西的好方法吗? 请参阅http://antonioleiva.com/kotlin-android-extension-functions/ 有没有更好的解决方案呢?