magic-5.kt

interface PushUpdates {

    val jobs: Observable<Job>

}

class SubscribedJobRepository(
    private val delegate: JobRepository,
    private val pushUpdates: PushUpdates
) : JobRepository by delegate {

    override fun getJob(jobId: String): Observable<Job> {
        return delegate.getJob(jobId)
                .concatWith(pushUpdates.jobs.filter {
                    it.id == jobId
                })
    }

}