.map { PostRemovedEvent(it) }
.forEach(eventBus::post)
newPostReplies
- .onEach { postReply -> if (postReply.time <= sone.followingTime) postReply.isKnown = true }
+ .onEach { postReply -> if (postReply.time <= sone.followingTime) database.setPostReplyKnown(postReply) }
.mapNotNull { postReply -> postReply.isKnown.ifFalse { NewPostReplyFoundEvent(postReply) } }
.forEach(eventBus::post)
removedPostReplies