тем более в новых JUnitах есть аннотация @DisplayName в которой можешь написать текстом лучше описание

Привет!
Подскажите пожалуйста как лучше в spring reactor решить проблему вызова mapping функции на  каждом flux.

Суть такая. Есть один publisher который дает стринги и есть клиенты, которые парсят пришедшие строки и фильтруют дто. Я организовал код вот так

val publisher: Flux<String> = ..

val sub1 = publisher.map{veryExpensiveConverter.convert(it)}
                   .filter(it.metric<10)

val sub2 = publisher.map{veryExpensiveConverter.convert(it)}
                   .filter(it.metric>5)

val sub3 = sub2.map{cheapConverter.convert(it)}
                   .filter(it.metric>8)

Flux.merge(sub1, sub2, sub3, ..., subn)
    .map{//some logic for following data of subscribers}
    .subscribe()

Но получаю что на каждый sub1, sub2, на те же самые входные строки будет вызываться
veryExpensiveConverter

Получается такое

Input1 -> 1) veryExpensiveConverter -> filter1 -> output1

                 2) -> veryExpensiveConverter -> filter2 -> output2

                 3) -> veryExpensiveConverter -> cheapConverter -> filter3 -> output3

А хотелось бы такое

Input1 -> veryExpensiveConverter ->
                                                             1)-> filter1 -> output1  
                                                             2)-> filter2 -> output2
                                                             3)-> cheapConverter -> filter3 -> output3

Как такое можно провернуть?

Мне кажется, для каждого теста это указывать немного муторно

Всем привет! Вопрос по стеку Netflix. Когда зарегестрированное приложение удаляется, она пропадает из Eureka мгновенно, но клиенты продолжают стучаться к нему в течении ~120c. Как я понимаю, register кэш не обновился у клиентов. Как ускорить процесс обновления регистров?

Конфиг сервера:
eureka:
   client:
       fetch-registry: false
       register-with-eureka: false
   server:
       response-cache-update-interval-ms: 1000

Клиент:
eureka:
 registryFetchIntervalSeconds: 1
   instance:
     leaseRenewalIntervalInSeconds: 1
 client:
   serviceUrl:
     defaultZone: http://localhost:8761/eureka
ribbon:
 ReadTimeout: 30000
 ConnectionTimeout: 5000
 ServerListRefreshInterval: 1000

должны помогать следующие параметры (значения специально выставлены очень мелкими, настолько мелкими не надо ;))

сервер
eureka:
 server:
   renewal-threshold-update-interval-ms: 1000
 instance:
   lease-expiration-duration-in-seconds: 2
   lease-renewal-interval-in-seconds: 1

клиент
eureka:
 client:
   initial-instance-info-replication-interval-seconds: 2
   instance-info-replication-interval-seconds: 1
   registry-fetch-interval-seconds: 1

Добрый день!
Подскажите, как можно сделать интерфейс, который бы расширял Comparable с самим собой.

Точнее как сделать реализацию метода compareTo.

Я сделал интерфейс

interface Version extends Comparable<Version>

Проблема, что метод compareTo принимает Version.

Получается, что реализовать его можно только с кастом? Или есть более красивые варианты?

>расширял Comparable с самим собой.
В смысле?

interface Version extends Comparable<Version>

Мне не нравится каст в реализации этого метода

Мне не нравится каст в реализации этого метода