connector-elasticsearch/com.river.connector.elasticsearch/toDocument

toDocument

@ExperimentalRiverApi
fun <T> Flow<T>.toDocument(f: (T) -> Pair<String, String>): Flow<Document<T>>