SearchTweetUseCase Flow collection

SearchTweetUseCase.kt

private val scope = CoroutineScope(taskThreading.uiDispatcher() + SupervisorJob())

@ExperimentalCoroutinesApi
override fun execute(query: String, callbackInput: SearchCallback?) {
   callback = callbackInput
   callback?.onShowLoader()
   scope.launch {
      repository.searchTweet(query)
        .catch { error ->
          // error handling
          onError(error)
        }.collect { tweets ->
          // UI actions for each stream
          onSuccess(tweets)
        }
   }
}