Java generics and reactive paradigm
I’m new to this reactive programming and I’m a little bit lost. I have a simple factory that retrieves the required class that implements a generic interface: public interface InterfaceToBeImplemented<T> { Flux<Tuple2<KafkaEvent<T>, String>> method(List<String> events); } public class InterfaceImplemntationOne implements InterfaceToBeImplented<ConcreteObject> { @Override public Flux<Tuple2<KafkaEvent<ConcreteObject>, String>> method(List<String> events) { …. } } And a service … Read more