Refactor RecordMapProcessor to include a more generic metadataProcess…

…or implementation.

src/main/java/no/ssb/dlp/pseudo/core/map/RecordMapProcessor.java

@@ -1,22 +1,18 @@
 package no.ssb.dlp.pseudo.core.map;
 
-import io.reactivex.processors.FlowableProcessor;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import no.ssb.dlp.pseudo.core.field.ValueInterceptorChain;
+import org.reactivestreams.Publisher;
 
 import java.util.Map;
 
 @RequiredArgsConstructor
 public class RecordMapProcessor<T> {
     private final ValueInterceptorChain valueInterceptorChain;
     @Getter
-    private final MetadataProcessor<T> metadataProcessor;
-    @FunctionalInterface
-    public interface MetadataProcessor<T> {
-        // The MetadataProcessor is used to publish/subscribe to events related to the processing of each RecordMap
-        FlowableProcessor<T> toFlowableProcessor();
-    }
+    private final T metadataProcessor;
+
     public Map<String, Object> init(Map<String, Object> r) {
         return MapTraverser.traverse(r, valueInterceptorChain::init);
     }