Shawn A
06/03/2019, 3:15 PMProcessor<K,V>
public interface ProcessorSupplier<K, V> {
Processor<K, V> get();
}
Given I have a class:
class EventNotifier : Processor<String, SomeEvent>`
I thought I'd be able to
call the Kstream#process(ProcessorSupplier<? super K, ? super V> var1, String... var2)
method, but I am getting
a type mismatch error for:
stream.process({ EventNotifier() })
>> Required: Processor<String!, SomeEvent!>!Found: () -> EventNotifier
karelpeeters
06/03/2019, 3:23 PMstream.process(ProcessorSupplier { EventNotifier() })
Shawn A
06/03/2019, 3:32 PMkarelpeeters
06/03/2019, 3:32 PM