From fac3d8f8567185f73814135fcfd626adeb0861ca Mon Sep 17 00:00:00 2001 From: InsanusMokrassar Date: Tue, 4 Sep 2018 10:25:30 +0800 Subject: [PATCH] added subsriptions constants --- .../PsychomatrixBase/utils/extensions/ReceiveChannel.kt | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/main/kotlin/com/github/insanusmokrassar/PsychomatrixBase/utils/extensions/ReceiveChannel.kt b/src/main/kotlin/com/github/insanusmokrassar/PsychomatrixBase/utils/extensions/ReceiveChannel.kt index 8be02b5..a4aa951 100644 --- a/src/main/kotlin/com/github/insanusmokrassar/PsychomatrixBase/utils/extensions/ReceiveChannel.kt +++ b/src/main/kotlin/com/github/insanusmokrassar/PsychomatrixBase/utils/extensions/ReceiveChannel.kt @@ -5,6 +5,12 @@ import kotlinx.coroutines.experimental.channels.BroadcastChannel import kotlinx.coroutines.experimental.channels.ReceiveChannel import java.util.concurrent.TimeUnit +const val SUBSCRIPTIONS_LARGE = 256 +const val SUBSCRIPTIONS_MEDIUM = 128 +const val SUBSCRIPTIONS_SMALL = 64 +const val SUBSCRIPTIONS_EXTRA_SMALL = 32 +const val SUBSCRIPTIONS_SINGLE = 1 + fun ReceiveChannel.subscribeChecking( throwableHandler: (Throwable) -> Boolean = { it.printStackTrace()