.subscribe( -> .filter(Objects::nonNull).collectList().block().forEach(

Author: pvlasov

src/main/java/org/nasdanika/launcher/Launcher.java

@@ -3,6 +3,7 @@
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
+import java.util.Objects;
 
 import org.nasdanika.capability.CapabilityLoader;
 import org.nasdanika.capability.CapabilityProvider;
@@ -27,7 +28,7 @@ public static void main(String[] args) {
 		List<CommandLine> rootCommands = new ArrayList<>();		
 		Requirement<SubCommandRequirement, CommandLine> subCommandRequirement = ServiceCapabilityFactory.createRequirement(CommandLine.class, null,  new SubCommandRequirement(Collections.emptyList()));
 		for (CapabilityProvider<Object> cp: capabilityLoader.load(subCommandRequirement, progressMonitor)) {
-			cp.getPublisher().subscribe(cmd -> rootCommands.add((CommandLine) cmd));
+			cp.getPublisher().filter(Objects::nonNull).collectList().block().forEach(cmd -> rootCommands.add((CommandLine) cmd));
 		}
 
 		// Executing the first one