1回答
我正在尝试从api中获取一些数据，并将它们存储在房间数据库中，所以主要的数据源是roomDatabase。非流版本工作:/我已经搜索了这个问题，但似乎没有什么工作。
浏览 17提问于2021-05-15得票数 0
我注意到，当表的最后一个值被删除时，流将不会发送值。正如我们所预期的那样，流的观察者得到了通知。然后直接移除表中的最后一株植物2。此更改不会发出，观察者也不会收到通知。我还注意到，如果在移除plant 1之后完全删除了应用程序，则再次启动该应用程序并删除第二个也是最后一个工厂，则会发出更改并通知观察者。
这是房间/流程中的错误吗？我使用Kotlin 1.3.72，Coroutines 1.3.6和Room 2.2.5
浏览 2提问于2020-05-12得票数 0
我正致力于在android应用程序中实现Room，我有一个用例，在这个用例中，我接收到当前用户id的流，其功能类似于切换到Google用户，将服务视为服务。我希望将该流传递到DAO中的一个@Query注释方法中，以获取用户小部件，以便如果当前选定的用户更改或存储的小部件列表发生更改，输出流也会发生变化。
浏览 0提问于2021-06-04得票数 2
回答已采纳
1回答
Kotlin流脱机缓存
、、、
我是kotlin flow的新手，我正在为这份文件工作。。在此代码中，每5秒数据源从api中获取数据并发布数据。我正在获取数据并发出数据。我正在绘制数据并保存它的房间数据库。我想从房间数据库中获取数据，并且因为单一的真理来源原理而发出数据，但是我仍然必须返回dataSource，因为如果我打开新的流{}，我无法访问数据源的数据。当然，我可以通过使用List来解决这个问题，而不是使用RemoteDataSource类中的流。但我想了解这个例子。我
浏览 3提问于2022-02-03得票数 2
嗨，我有一个rxJava可观测和平面图，我想把它转换成kotlin协同流。
浏览 5提问于2021-01-13得票数 0
由于RxJava2使用的JSON键命名约定，我正在努力在我的Kotlin应用程序中跨Retrofit、Room和API保持一致的类型。如果我向单个用户发出API请求，该API将返回以下内容： { "id": 1, }
} 如果我向多个用户发出API请求，该API将返回以下内容设置房间以返回User或List<User>形式的查询，这在RxJava2流中使用
浏览 46提问于2019-02-18得票数 0
回答已采纳
在Kotlin中，有一个函数：
返回一个流，该流在原始流每次发出值时切换到由transform函数生成的新流。当原始流发出一个新值时，由transform块产生的先前流被取消。
浏览 5提问于2022-10-03得票数 0
1回答
Kotlin流的移动窗口
、、、
我正在尝试使用Kotlin流创建一个移动的数据窗口。它可以在RxKotlin中使用缓冲区来实现，但是使用流的缓冲区是不同的。RxKotlin有一个buffer运算符，周期性地将可观察到的项收集到包中，并发出这些包，而不是一次只发出一个- 。Kotlin流有一个buffer，但它只是在单独的coroutine 中运行一个收集器。
在流中是否有一个现有的操作符可以实现这一点？
浏览 14提问于2021-12-12得票数 5
2回答
我从房间的数据库里找到了一系列的剧情。我可以像实时数据一样观察这个流，没有任何问题。 但我也希望在用户单击按钮时读取该流中的最后一个值。我尝试使用first()终端流运算符，但它不能编译。非编译尝试从流中读取： bd.buttonNext.setOnClickListener { val episode: Episodename}", Snackbar.LENGTH_SHORT).show()} 此流来自<em
浏览 28提问于2021-02-11得票数 6
回答已采纳
Rx具有表示不会通知任何内容的Observable.empty()。 在Android架构组件LiveData中有没有等同的类(或其他东西)？
浏览 10提问于2020-10-01得票数 0
2回答
流-暂停/恢复流
、、
在RxJava中，有一个<code>D0</code>操作符，它允许暂停(和缓冲)流，并再次恢复流(还可以在恢复时立即发出缓冲值)。它是rx java扩展(<code>C1</code>)的一部分。kotlin flows也有类似的东西吗？
我的用例是，我希望观察活动内部的流，并且永远不会丢失事件(就像我在<code>D2</code>中所做的那样，如果活动暂停，它就会停止观察数据)。因此，当活动暂停时，
浏览 15提问于2021-03-15得票数 2
当我们使用Spring的RSocket ()支持使用Kotlin流和反应堆流发出值时，IO流量有什么不同吗？另外，客户端代码(带有rsocket-websocket-client的JS)应该是不同的，这取决于服务器是使用Kotlin流还是反应堆流量？
浏览 3提问于2021-03-26得票数 2
回答已采纳
我使用Room和Flows制作了一个简单的示例应用程序： class MainActivity : AppCompatActivity() { super.onCreate(savedInstanceState) val build = Room.databaseBuilder(this, FinanceDatabase::class.java, "database.db"
浏览 69提问于2020-06-21得票数 4
回答已采纳
使用Room数据库和Kotlin，这就是我获得可流性的地方 Timber.d("District
浏览 2提问于2017-10-03得票数 3
回答已采纳
1回答
嘿，我使用一个模型作为DTO、JsonCreator和Percelize --我的问题是，我想使用多态性(分解公共部分)，而不知道如何用Kotlin编写它。MapsMarker(lat: Double, lng: Double, var name: String): Location(lat, lng), Parcelable如果有人知道答案，请帮助我;)
浏览 7提问于2017-11-21得票数 6
1回答
我在一个安卓应用程序中遇到了一个问题，Kotlin的flow将不再能够执行它体内指定的相同代码，而它以前已经被执行并且失败了(因此发出了一个异常)。既然Kotlin的流像流一样工作，那么在失败后，我能重用相同的流来发出新的值吗？例如:执行了一个流来执行网络请求，但由于某种原因失败了，如果用户单击“重试”，以便我可以使用相同的流并重试相同的执行，这将是一个很好的用例。Kotlin的flow的“重试”操作符在我的用例中有用吗？
而且，我知道如果我创建一个新
浏览 3提问于2022-01-26得票数 1
回答已采纳
我正在观察一个来自Kotlin类的RxJava2流。Kotlin正在将这些转换为可观测/单/平台类型(例如Observable<Widget!>)的流程。我知道很少有人谈论那个
因此，既然RxJava2不能发出null，那么我能安全地假设任何发出的类型都是不可空的Kotlin类型吗？
浏览 4提问于2019-11-19得票数 0
回答已采纳
2回答
我有一个DAO接口，其中有多个实现，我希望其中之一是一个房间实现(Kotlin)： fun getAll(): Single<List<SomeData>>}@Dao这是已知的bug，还是Room编
浏览 8提问于2017-12-07得票数 13
1回答
我想为Kotlin流的永远循环和发出结果创建一个很好的逻辑。用例是，每n分钟我需要更新应用程序中的一个配置，该配置来自rest api。我认为一个很好的解决方案是运行一个“调度器”，在后台每n分钟轮询api一次，当调度器发出一个新值时，订阅这个调度器的ConfigService可以更新它自己的状态。使用RxJava，这将是 Observable.interval(n, TimeUnit.MINUTES)
.flatMap( ... ) 但是由于我使用的是Kotlin</em
浏览 103提问于2020-07-20得票数 4
回答已采纳
2回答
RxJava用于实时数据错误处理
、、、、
因此，在我的android项目中，我在存储库层使用RxJava，然后将其转换为视图模型中的实时数据，但是当流发出错误时，我有一个异常。这和的这句话有关
fromPublisher (Publisher<T> publisher)
从一个发布服务器创建一个可观察的ReactiveStreams流。LiveData保存发布服务器在LiveData处于活动状态时发出的最后一个值。请注意，LiveData不处理错误，它期望将错误视为所保存的数据中的状态。如果发布服务器<
浏览 0提问于2018-07-03得票数 1
云服务器
ICP备案
实时音视频
云直播
对象存储
腾讯云开发者
