Communicator

BottomSheetDialogCommunicator.kt

@PerActivity
class BottomSheetDialogCommunicator @Inject constructor() {
    val flow = MutableSharedFlow<BottomSheetDialogMessage>()
}

sealed interface BottomSheetDialogMessage

sealed interface ReminderMessage : BottomSheetDialogMessage {
    data class Test(val text: String) : ReminderMessage
}

Listener.kt

@Inject lateinit var communicator: BottomSheetDialogCommunicator

override fun onCreate(...) {
  ...
  lifecycleScope.launch {
      communicator.flow
          .flowWithLifecycle(lifecycle, Lifecycle.State.STARTED)
          .collectType { message: ReminderMessage.Type
              Log.i("EditorActivity", message.text)
          }
  }
}

private suspend inline fun <T, reified U : T> Flow<T>.collectType(crossinline collector: (U) -> Unit) =
        collect {
            if (it is U) collector(it)
        }