postgresChangeFlowInternal
abstract fun <T : PostgresAction> RealtimeChannel.postgresChangeFlowInternal(action: KClass<T>, schema: String, filter: PostgresChangeFilter.() -> Unit = {}): Flow<T>(source)
Non-inline variant of postgresChangeFlow for implementation and mocking purposes