上下文:我有一个应用程序的日志库,我想使用Rx Subject将日志写入数据库。问题:日志是在建立到数据库的连接之前生成的,连接可能在任何时候变得不可用,但我观察到,要么包含一个带有使用数据库的方法的对象,要么包含一个未定义的对象。我想做的是在数据库持久化未定义时将日志保留在流中,并在可用时恢复。
我认为代码应该是这样的:
logsSubject
.takeWhen(/* test for database persistence */) // made up name because I don't know a Rx method that does what