Mark read when blocking conversation

import io.reactivex.Flowable

import javax.inject.Inject

class MarkBlocked @Inject constructor(private val conversationRepo: ConversationRepository) : Interactor<List<Long>>() {

class MarkBlocked @Inject constructor(

    private val conversationRepo: ConversationRepository,

    private val markRead: MarkRead

) : Interactor<List<Long>>() {

    override fun buildObservable(params: List<Long>): Flowable<*> {

        return Flowable.just(params.toLongArray())

                .doOnNext { threadIds -> conversationRepo.markBlocked(*threadIds) }

                .flatMap { markRead.buildObservable(params) }

    }

}

 No newline at end of file