use UnaryOperator

eclipse-ditto · Mar 8, 2019 · ce10999 · ce10999
1 parent 6d82f56
commit ce10999
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/...rg/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionMigrationUtil.java b/...rg/eclipse/ditto/services/connectivity/messaging/persistence/ConnectionMigrationUtil.java
@@ -11,7 +11,6 @@
 package org.eclipse.ditto.services.connectivity.messaging.persistence;
 
 import java.util.Optional;
-import java.util.function.Function;
 import java.util.function.UnaryOperator;
 import java.util.regex.Pattern;
 import java.util.stream.IntStream;
@@ -63,9 +62,9 @@ private ConnectionMigrationUtil() {
      * @return the (potentially migrated) Connection instance
      */
     static Connection connectionFromJsonWithMigration(@Nonnull final JsonObject connectionJsonObject) {
-        final Function<JsonObject, JsonObject> migrateSourceFilters = new MigrateSourceFilters();
-        final Function<JsonObject, JsonObject> migrateTopicActionSubjectFilters = new MigrateTopicActionSubjectFilters();
-        final Function<JsonObject, JsonObject> migrateAuthorizationContexts = new MigrateAuthorizationContexts();
+        final UnaryOperator<JsonObject> migrateSourceFilters = new MigrateSourceFilters();
+        final UnaryOperator<JsonObject> migrateTopicActionSubjectFilters = new MigrateTopicActionSubjectFilters();
+        final UnaryOperator<JsonObject> migrateAuthorizationContexts = new MigrateAuthorizationContexts();
 
         return ConnectivityModelFactory.connectionFromJson(
                 migrateAuthorizationContexts