@Override
    public Publisher<IPayload> get(DataFetchingEnvironment environment) throws Exception {
        Object argument = environment.getArgument("input"); //$NON-NLS-1$
        var input = this.objectMapper.convertValue(argument, MapEventInput.class);
        var mapConfiguration = new MapConfiguration(input.getMapId());
        
        return this.editingContextEventProcessorRegistry.getOrCreateEditingContextEventProcessor(input.getEditingContextId())
                .flatMap(processor -> processor.acquireRepresentationEventProcessor(IMapEventProcessor.class, mapConfiguration, input))
                .map(representationEventProcessor -> representationEventProcessor.getOutputEvents(input)).orElse(Flux.empty());
    }

    @Override
    public Flux<IPayload> getOutputEvents(IInput input) {
        return Flux.merge(this.mapEventFlux.getFlux(input), this.subscriptionManager.getFlux(input));
    }