Refactor RecordMapProcessor to include a more generic metadataProcess…

…or implementation. (#34)

* Refactor RecordMapProcessor to include a more generic metadataProcessor implementation.

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

@@ -1,6 +1,5 @@
 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;
@@ -11,12 +10,8 @@
 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);
     }