dave08
01/17/2023, 11:27 AMToshihiro Nakamura
01/17/2023, 11:52 AMval connectionFactory = object : ConnectionFactory {
override fun create(): Publisher<out Connection> {
// return existing connection
}
override fun getMetadata(): ConnectionFactoryMetadata {
// ...
}
}
val db = R2dbcDatabase(connectionFactory, H2R2dbcDialect())
dave08
01/17/2023, 11:54 AMToshihiro Nakamura
01/17/2023, 12:04 PMflowOf(connection).asPublisher()
dave08
01/17/2023, 12:05 PM