R2DBC + MyBatis

DemoMapper.java

package org.mybatis.r2dbc.session;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public interface DemoMapper {

  Mono<Integer> insert(Demo demo);

  Mono<Integer> insert(Mono<Demo> demo);

  Mono<Boolean> update(Demo demo);

  Flux<Demo> select();

  class Demo {
  }

}

ReactorSqlSession.java

package org.mybatis.reactive;

import org.reactivestreams.Publisher;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public interface ReactorSqlSession extends ReactiveSqlSession {

  @Override
  default <T> Flux<T> select(String statementId, Class<T> returnType) {
    return select(statementId, (Object) null, returnType);
  }

  @Override
  default <T> Flux<T> select(String statementId, Object parameter, Class<T> returnType) {
    return select(statementId, parameter == null ? null : Mono.just(parameter), returnType);
  }

  @Override
  <T> Flux<T> select(String statementId, Publisher<Object> parameterPublisher, Class<T> returnType);

  @Override
  default Mono<Integer> insert(String statementId) {
    return insert(statementId, (Object) null);
  }

  @Override
  default Mono<Integer> insert(String statementId, Object parameter) {
    return insert(statementId, parameter == null ? null : Mono.just(parameter));
  }

  @Override
  Mono<Integer> insert(String statementId, Publisher<Object> parameterPublisher);

  @Override
  default Mono<Integer> update(String statementId) {
    return update(statementId, (Object) null);
  }

  @Override
  default Mono<Integer> update(String statementId, Object parameter) {
    return update(statementId, parameter == null ? null : Mono.just(parameter));
  }

  @Override
  Mono<Integer> update(String statementId, Publisher<Object> parameter);

  @Override
  default Mono<Integer> delete(String statementId) {
    return delete(statementId, (Object) null);
  }

  @Override
  default Mono<Integer> delete(String statementId, Object parameter) {
    return update(statementId, parameter == null ? null : Mono.just(parameter));
  }

  @Override
  default Mono<Integer> delete(String statementId, Publisher<Object> parameterPublisher) {
    return update(statementId, parameterPublisher);
  }

  @Override
  Mono<Void> begin();

  @Override
  Mono<Void> commit();

  @Override
  Mono<Void> rollback();

  @Override
  Mono<Void> close();

}