smaldini

// AeronProcessor as a server
AeronProcessor server = AeronProcessor.builder()
                .senderChannel("udp://localhost:12000")
                .receiverChannel("udp://localhost:12001")
                .senderOnly(true)
                .create();

// Read file bytes on server command        
IO.readFile("~/test.txt")
.subscribe(server);

smaldini

// Create an async message-passing Processor exposing a Flux API
TopicProcessor<String> sink = TopicProcessor.create();

// Scatter Gather the input sequence
sink
  .map(String::toUpperCase)
  .flatMap(s -> 
      Mono.fromCallable(() -> someRepository.findOneByCategory(s))
          .timeout(Duration.ofSeconds(3), someRepository::fallback)
          .subscribeOn(Schedulers.parallel())

smaldini

includeTargets << grailsScript("_GrailsInit")
includeTargets << grailsScript("_GrailsTest")
includeTargets << grailsScript("_GrailsWar")

target(main: "Clean, Test, and War") {
        clean()
	allTests()    // results in (1)
	//packageApp() not needed
	warCreator.configureWarName()    
	war()