Added Operators.onDiscard

artem-v · artem-v · commit f426b8d3de80 · 2021-04-12T21:23:30.000+03:00
diff --git a/services-discovery/src/main/java/io/scalecube/services/discovery/ScalecubeServiceDiscovery.java b/services-discovery/src/main/java/io/scalecube/services/discovery/ScalecubeServiceDiscovery.java
@@ -46,7 +46,7 @@ public final class ScalecubeServiceDiscovery implements ServiceDiscovery {
   private static final Logger LOGGER = LoggerFactory.getLogger(ServiceDiscovery.class);
 
   static {
-    Operators.enableOnDiscard(null, obj -> LOGGER.warn("[onDiscard] obj = {}", obj));
+    Operators.enableOnDiscard(null, o -> LOGGER.warn("[onDiscard] element = {}", o));
   }
 
   private final ServiceEndpoint serviceEndpoint;

Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ public final class ScalecubeServiceDiscovery implements ServiceDiscovery {`
`46`	`46`	`private static final Logger LOGGER = LoggerFactory.getLogger(ServiceDiscovery.class);`
`47`	`47`
`48`	`48`	`static {`
`49`		`- Operators.enableOnDiscard(null, obj -> LOGGER.warn("[onDiscard] obj = {}", obj));`
	`49`	`+ Operators.enableOnDiscard(null, o -> LOGGER.warn("[onDiscard] element = {}", o));`
`50`	`50`	`}`
`51`	`51`
`52`	`52`	`private final ServiceEndpoint serviceEndpoint;`