connector-format-positional-flat-line/com.river.connector.format.positional.flat.line

Package-level declarations

Types

@ExperimentalRiverApi

data class Field<T>(val name: String, val padding: Char, val range: IntRange, val parser: (String) -> T)

@ExperimentalRiverApi

class RecordBuilder

@ExperimentalRiverApi

data class RecordDef(val fields: Map<String, Field<*>>)

Functions

@ExperimentalRiverApi

infix fun <T> Map<String, Any?>.mappedAs(f: (Map<String, Any?>) -> T): T

@ExperimentalRiverApi

infix fun String.parsedTo(record: RecordDef): Map<String, Any?>

@ExperimentalRiverApi

fun record(builder: RecordBuilder.() -> Unit): RecordDef

toPositionalFlatLine

@ExperimentalRiverApi

fun Flow<String>.toPositionalFlatLine(record: RecordDef): Flow<Map<String, Any?>>

@ExperimentalRiverApi

fun Flow<String>.toPositionalFlatLine(record: RecordBuilder.() -> Unit): Flow<Map<String, Any?>>

@ExperimentalRiverApi

fun <T> Flow<String>.toPositionalFlatLine(record: RecordDef, f: (Map<String, Any?>) -> T): Flow<T>

@ExperimentalRiverApi

fun <T> Flow<String>.toPositionalFlatLine(mappedAs: (Map<String, Any?>) -> T, record: RecordBuilder.() -> Unit): Flow<T>