connector-console/com.river.connector.console

Package-level declarations

Types

OutType

enum OutType : Enum<OutType>

enum Print : Enum<Print>

Functions

consoleIn

@ExperimentalCoroutinesApi

fun consoleIn(dispatcher: CoroutineDispatcher = Dispatchers.IO.limitedParallelism(1)): Flow<String>

Creates a flow of strings read from the console input (stdin) using the specified dispatcher.

consoleOut

@ExperimentalCoroutinesApi

fun <T : Any> Flow<T>.consoleOut(dispatcher: CoroutineDispatcher = Dispatchers.IO.limitedParallelism(1), print: Print = Print.BREAK_LINE, mapper: suspend (T) -> Pair<Any, OutType> = { it to OutType.DEFAULT }): Flow<Pair<Any, OutType>>

Outputs the flow of objects to the console (stdout or stderr) using the specified dispatcher, print, and mapper.