Skip to content

Assembler v0.7.7

Latest
Latest
Compare
Choose a tag to compare
@pellse pellse released this 05 Dec 05:43
· 7 commits to main since this release
v0.7.7
7fc69c6

What's Changed

  • The Auto Caching API was renamed to Stream Table to better reflect what the API does, which is conceptually similar to what a KTable is with Apache Kafka:
Flux<BillingInfo> billingInfoFlux = ... // From e.g. Debezium/Kafka, RabbitMQ, etc.;
Flux<OrderItem> orderItemFlux = ... // From e.g. Debezium/Kafka, RabbitMQ, etc.;

var assembler = assemblerOf(Transaction.class)
  .withCorrelationIdResolver(Customer::customerId)
  .withRules(
    rule(BillingInfo::customerId,
      oneToOne(cached(call(this::getBillingInfo), streamTable(billingInfoFlux)))),
    rule(OrderItem::customerId,
      oneToMany(OrderItem::id, cachedMany(call(this::getAllOrders), streamTable(orderItemFlux)))),
    Transaction::new)
  .build();

var transactionFlux = getCustomers()
  .window(3)
  .flatMapSequential(assembler::assemble);
  • Optimizations in reactive read-write lock implementation and ReactiveGuard high level api
  • Updated Project Reactor to version 3.7.0 to match the release of Spring Boot 3.4.0
Assets 2
Loading