executeQueryAsFlow

fun <R> executeQueryAsFlow(identifier: Int?, sql: String, mapper: suspend (PostgresCursor) -> R, parameters: Int, fetchSize: Int = 10, binders: PostgresPreparedStatement.() -> Unit?): Flow<R>