Class InsertionTask<T1,T2 extends ModelWithJsonPayload<T1>>

java.lang.Object
energy.eddie.outbound.rest.tasks.InsertionTask<T1,T2>

public class InsertionTask<T1,T2 extends ModelWithJsonPayload<T1>> extends Object
  • Constructor Details

    • InsertionTask

      public InsertionTask(reactor.core.publisher.Flux<T1> flux, org.springframework.data.jpa.repository.JpaRepository<T2,Long> repository, Function<T1,T2> converter)
  • Method Details

    • insert

      public void insert(T1 payload)