coroutines/dev.funkymuse.coroutines

Package-level declarations

Types

AbortCollectException

class AbortCollectException : CancellationException

AutoDisposableJob

class AutoDisposableJob(view: View, wrapped: Job) : Job, View.OnAttachStateChangeListener

ExactlyOnceEventBus

class ExactlyOnceEventBus<T>

Properties

defaultDispatcher

val defaultDispatcher: CoroutineDispatcher

ioDispatcher

val ioDispatcher: CoroutineDispatcher

mainDispatcher

val mainDispatcher: MainCoroutineDispatcher

unconfinedDispatcher

val unconfinedDispatcher: CoroutineDispatcher

Functions

asAutoDisposable

fun Job.asAutoDisposable(view: View): AutoDisposableJob

cancelIfActive

fun Job?.cancelIfActive()

Cancel the Job if it's active.

default

inline fun CoroutineScope.default(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, crossinline function: suspend () -> Unit): Job

defaultCoroutine

fun AppCompatActivity.defaultCoroutine(action: suspend (scope: CoroutineScope) -> Unit = {}): Job

fun Fragment.defaultCoroutine(action: suspend (scope: CoroutineScope) -> Unit = {}): Job

defaultCoroutineGlobal

fun <T> defaultCoroutineGlobal(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, block: suspend () -> T): Job

doParallel

suspend fun doParallel(vararg blocks: suspend () -> Any)

doParallelWithResult

suspend fun <T> doParallelWithResult(vararg blocks: suspend () -> T): MutableList<T>

highPriorityContext

fun highPriorityContext(): ExecutorCoroutineDispatcher

inline fun CoroutineScope.io(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, crossinline function: suspend () -> Unit): Job

ioCoroutine

fun AppCompatActivity.ioCoroutine(action: suspend (scope: CoroutineScope) -> Unit = {}): Job

fun Fragment.ioCoroutine(action: suspend (scope: CoroutineScope) -> Unit = {}): Job

ioCoroutineGlobal

fun <T> ioCoroutineGlobal(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, block: suspend () -> T): Job

main

inline fun CoroutineScope.main(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, crossinline function: suspend () -> Unit)

mainCoroutine

fun AppCompatActivity.mainCoroutine(action: suspend (scope: CoroutineScope) -> Unit = {}): Job

fun Fragment.mainCoroutine(action: suspend (scope: CoroutineScope) -> Unit = {}): Job

mainCoroutineGlobal

fun <T> mainCoroutineGlobal(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, block: suspend () -> T): Job

makeIOCall

inline fun AndroidViewModel.makeIOCall(crossinline onCallExecuted: () -> Unit = {}, crossinline ioCall: suspend () -> Unit): Job

inline fun CoroutineScope.makeIOCall(crossinline onCallExecuted: () -> Unit = {}, crossinline ioCall: suspend () -> Unit): Job

inline fun AndroidViewModel.makeIOCall(crossinline onCallExecuted: () -> Unit = {}, crossinline onErrorAction: (throwable: Throwable) -> Unit = { _ -> }, crossinline ioCall: suspend () -> Unit): Job

inline fun CoroutineScope.makeIOCall(crossinline onCallExecuted: () -> Unit = {}, crossinline onErrorAction: (throwable: Throwable) -> Unit = { _ -> }, crossinline ioCall: suspend () -> Unit): Job

inline fun <T> AndroidViewModel.makeIOCall(crossinline onCallExecuted: () -> Unit = {}, crossinline onErrorAction: (throwable: Throwable) -> Unit = { _ -> }, crossinline ioCall: suspend () -> T, crossinline onCalled: (model: T) -> Unit): Job

inline fun <T> CoroutineScope.makeIOCall(crossinline onCallExecuted: () -> Unit = {}, crossinline onErrorAction: (throwable: Throwable) -> Unit = { _ -> }, crossinline ioCall: suspend () -> T, crossinline onCalled: (model: T) -> Unit): Job

nonCancellable

inline suspend fun <T> nonCancellable(crossinline block: CoroutineScope.() -> T): T

nonCancellable

inline suspend fun <T, R> T.nonCancellable(crossinline block: (T) -> R): R

inline fun CoroutineScope.nonCancellable(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, crossinline function: suspend () -> Unit): Job

nonCancellableCoroutine

fun AppCompatActivity.nonCancellableCoroutine(action: suspend (scope: CoroutineScope) -> Unit = {}): Job

fun Fragment.nonCancellableCoroutine(action: suspend (scope: CoroutineScope) -> Unit = {}): Job

offerIfNotClosed

fun <E> ProducerScope<E>.offerIfNotClosed(element: E)

onDefault

inline suspend fun <T> onDefault(crossinline block: CoroutineScope.() -> T): T

onDefault

inline suspend fun <T, R> T.onDefault(crossinline block: (T) -> R): R

onIO

inline suspend fun <T> onIO(crossinline block: CoroutineScope.() -> T): T

onIO

inline suspend fun <T, R> T.onIO(crossinline block: (T) -> R): R

onMain

inline suspend fun <T> onMain(crossinline block: CoroutineScope.() -> T): T

onMain

inline suspend fun <T, R> T.onMain(crossinline block: (T) -> R): R

repeat

fun <T> Flow<T>.repeat(): Flow<T>

sendIfNotClosed

suspend fun <E> ProducerScope<E>.sendIfNotClosed(element: E)

setOnClickCoroutine

fun View.setOnClickCoroutine(owner: LifecycleOwner, listener: suspend (view: View) -> Unit)

textChanges

fun EditText.textChanges(skipInitialValue: Boolean = false, debounce: Long = 300): Flow<CharSequence?>

fun TextView.textChanges(skipInitialValue: Boolean = false, debounce: Long = 300): Flow<CharSequence?>

toBitmapSuspend

suspend fun ByteArray.toBitmapSuspend(): Bitmap?

unconfined

inline fun CoroutineScope.unconfined(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, crossinline function: suspend () -> Unit): Job

unconfinedCoroutine

fun AppCompatActivity.unconfinedCoroutine(action: suspend (scope: CoroutineScope) -> Unit = {}): Job

fun Fragment.unconfinedCoroutine(action: suspend (scope: CoroutineScope) -> Unit = {}): Job

unconfinedCoroutineGlobal

fun <T> unconfinedCoroutineGlobal(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, block: suspend () -> T): Job

viewModelDefaultCoroutine

fun ViewModel.viewModelDefaultCoroutine(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, action: suspend (scope: CoroutineScope) -> Unit = {}): Job

viewModelIOCoroutine

fun ViewModel.viewModelIOCoroutine(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, action: suspend (scope: CoroutineScope) -> Unit = {}): Job

viewModelMainCoroutine

fun ViewModel.viewModelMainCoroutine(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, action: suspend (scope: CoroutineScope) -> Unit = {}): Job

viewModelNonCancellableCoroutine

fun ViewModel.viewModelNonCancellableCoroutine(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, action: suspend (scope: CoroutineScope) -> Unit = {}): Job

viewModelUnconfinedCoroutine

fun ViewModel.viewModelUnconfinedCoroutine(coroutineStart: CoroutineStart = CoroutineStart.DEFAULT, action: suspend (scope: CoroutineScope) -> Unit = {}): Job

withDefaultContext

suspend fun <T> withDefaultContext(block: suspend () -> T): T

withIOContext

suspend fun <T> withIOContext(block: suspend () -> T): T

withMainContext

suspend fun <T> withMainContext(block: suspend () -> T): T

withNonCancellableContext

suspend fun <T> withNonCancellableContext(block: suspend () -> T): T

withUnconfinedContext

suspend fun <T> withUnconfinedContext(block: suspend () -> T): T