Searched refs:processMap (Results 1 – 2 of 2) sorted by relevance
33 final Map<String, AsyncProcessFunction<I, ? extends TBase, ?>> processMap; field in TBaseAsyncProcessor36 I iface, Map<String, AsyncProcessFunction<I, ? extends TBase, ?>> processMap) { in TBaseAsyncProcessor() argument38 this.processMap = processMap; in TBaseAsyncProcessor()42 return Collections.unmodifiableMap(processMap); in getProcessMapView()52 AsyncProcessFunction fn = processMap.get(msg.name); in process()
13 private final Map<String, ProcessFunction<I, ? extends TBase>> processMap; field in TBaseProcessor18 this.processMap = processFunctionMap; in TBaseProcessor()22 return Collections.unmodifiableMap(processMap); in getProcessMapView()28 ProcessFunction fn = processMap.get(msg.name); in process()