Receiving reactive objects in the repository interface

[averri]

Is it possible to save/update using reactive objects in the function arguments of reactive repositories?

Example: I would like to be able to save an entity of class com.mydomain.entity.User using:

import com.mydomain.entity.User
import io.micronaut.data.model.query.builder.sql.Dialect
import io.micronaut.data.r2dbc.annotation.R2dbcRepository
import io.micronaut.data.repository.reactive.ReactiveStreamsPageableRepository
import org.reactivestreams.Publisher

@R2dbcRepository(dialect = Dialect.POSTGRES)
interface UserRepository: ReactiveStreamsPageableRepository<Long, User> {
    
    fun save(user: Publisher<User>): Publisher<User>
}

This is extremely useful for use in conjunction with reactive controllers, which can accept function arguments using Publisher<T> where T is the generic object type.

[dstepanov]

It's not possible right now. Please create an issue.

[averri]

Thanks, @dstepanov. I have created this one, let me know if the information is not clear:
#2049