/
ToolbarNavigationClicks.kt
110 lines (102 loc) · 3.66 KB
/
ToolbarNavigationClicks.kt
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
/*
* Copyright 2019 Vladimir Raupov
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package ru.ldralighieri.corbind.appcompat
import android.view.View
import androidx.annotation.CheckResult
import androidx.appcompat.widget.Toolbar
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.channels.ReceiveChannel
import kotlinx.coroutines.channels.actor
import kotlinx.coroutines.channels.awaitClose
import kotlinx.coroutines.coroutineScope
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.channelFlow
import kotlinx.coroutines.isActive
import ru.ldralighieri.corbind.corbindReceiveChannel
import ru.ldralighieri.corbind.offerElement
/**
* Perform an action on [Toolbar] navigation click events.
*
* *Warning:* The created actor uses [Toolbar.setNavigationOnClickListener] to emit clicks. Only
* one actor can be used for a view at a time.
*
* @param scope Root coroutine scope
* @param capacity Capacity of the channel's buffer (no buffer by default)
* @param action An action to perform
*/
fun Toolbar.navigationClicks(
scope: CoroutineScope,
capacity: Int = Channel.RENDEZVOUS,
action: suspend () -> Unit
) {
val events = scope.actor<Unit>(Dispatchers.Main, capacity) {
for (unit in channel) action()
}
setNavigationOnClickListener(listener(scope, events::offer))
events.invokeOnClose { setNavigationOnClickListener(null) }
}
/**
* Perform an action on [Toolbar] navigation click events, inside new [CoroutineScope].
*
* *Warning:* The created actor uses [Toolbar.setNavigationOnClickListener] to emit clicks. Only
* one actor can be used for a view at a time.
*
* @param capacity Capacity of the channel's buffer (no buffer by default)
* @param action An action to perform
*/
suspend fun Toolbar.navigationClicks(
capacity: Int = Channel.RENDEZVOUS,
action: suspend () -> Unit
) = coroutineScope {
navigationClicks(this, capacity, action)
}
/**
* Create a channel which emits on [Toolbar] navigation click events.
*
* *Warning:* The created channel uses [Toolbar.setNavigationOnClickListener] to emit clicks.
* Only one channel can be used for a view at a time.
*
* @param scope Root coroutine scope
* @param capacity Capacity of the channel's buffer (no buffer by default)
*/
@CheckResult
fun Toolbar.navigationClicks(
scope: CoroutineScope,
capacity: Int = Channel.RENDEZVOUS
): ReceiveChannel<Unit> = corbindReceiveChannel(capacity) {
setNavigationOnClickListener(listener(scope, ::offerElement))
invokeOnClose { setNavigationOnClickListener(null) }
}
/**
* Create a flow which emits on [Toolbar] navigation click events.
*
* *Warning:* The created flow uses [Toolbar.setNavigationOnClickListener] to emit clicks. Only
* one flow can be used for a view at a time.
*/
@CheckResult
fun Toolbar.navigationClicks(): Flow<Unit> = channelFlow {
setNavigationOnClickListener(listener(this, ::offer))
awaitClose { setNavigationOnClickListener(null) }
}
@CheckResult
private fun listener(
scope: CoroutineScope,
emitter: (Unit) -> Boolean
) = View.OnClickListener {
if (scope.isActive) { emitter(Unit) }
}