Превращение слушателей в каналы котлин сопрограммы - PullRequest
Новая
       5

Превращение слушателей в каналы котлин сопрограммы

0 голосов
/ 06 февраля 2019

У меня есть несколько функций, которые я хочу использовать для создания конвейеров с Channel s.Основным является globalLayouts, где я создаю Channel из слушателя фреймворка: 

fun View.globalLayouts(): ReceiveChannel<View> =
    Channel<View>().apply {
        val view = this@globalLayouts

        val listener = ViewTreeObserver.OnGlobalLayoutListener {
            offer(view)
        }

        invokeOnClose {
            viewTreeObserver.removeOnGlobalLayoutListener(listener)
        }

        viewTreeObserver.addOnGlobalLayoutListener(listener)
    }

@UseExperimental(InternalCoroutinesApi::class)
fun <E> ReceiveChannel<E>.distinctUntilChanged(context: CoroutineContext = Dispatchers.Unconfined): ReceiveChannel<E> =
    GlobalScope.produce(context, onCompletion = consumes()) {
        var last: Any? = Any()

        consumeEach {
            if (it != last) {
                send(it)
                last = it
            }
        }
    }

fun View.keyboardVisibility(): ReceiveChannel<KeyboardVisibility> {
    val rect = Rect()

    return globalLayouts()
        .map {
            getWindowVisibleDisplayFrame(rect)

            when (rect.height()) {
                height -> KeyboardVisibility.HIDDEN
                else -> KeyboardVisibility.SHOWN
            }
        }
        .distinctUntilChanged()
}

У меня есть CoroutineScope с именем alive: 

val ControllerLifecycle.alive: CoroutineScope
    get() {
        val scope = MainScope()

        addLifecycleListener(object : Controller.LifecycleListener() {
            override fun preDestroyView(controller: Controller, view: View) {
                removeLifecycleListener(this)
                scope.cancel()
            }
        })

        return scope
    }

затемЯ делаю: 

alive.launch {
    root.keyboardVisibility().consumeEach {
        appbar.setExpanded(it == KeyboardVisibility.HIDDEN)
    }
}

Этот код начинает работать нормально, но я получаю 

kotlinx.coroutines.JobCancellationException: Job was cancelled; job=JobImpl{Cancelled}@811031f

, как только моя область действия alive будет уничтожена.Сразу после вызова invokeOnClose в globalLayouts.Что я делаю не так и как мне это отладить?

1 Ответ

0 голосов
/ 06 февраля 2019

Разобрался - код работает нормально, но 

viewTreeObserver.removeOnGlobalLayoutListener(listener)

содержит ошибки для CoordinatorLayout.

...