kartikeytewari-ul
commented
1 week ago This is fixed with v0.6.101 video demo
Closed kartikeytewari-ul closed 1 week ago
kartikeytewari-ul
commented
1 week ago This is fixed with v0.6.101 video demo
kartikeytewari-ul
commented
1 week ago For checking the decompiled file do not use fern-flower decompiler (the default decompilation done by Intellij Idea) since it would not show the probed lambda methods. Instead useprocyon-decompiler, as it will show probed lambda methods with a synthetic comment with them.
TheAmg
commented
1 week ago Closing the issue, both probed and unprobed methods are created. Probed lambdas are also listed.
CronController decompiled class ->
package org.unlogged.springwebfluxdemo.controller;
import io.unlogged.Runtime;
import io.unlogged.logging.Logging;
import java.util.HashMap;
import java.util.function.Function;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.unlogged.springwebfluxdemo.service.CronService;
import reactor.core.publisher.Mono;
@RestController
@RequestMapping({"/cron"})
public class CronController {
private final CronService cronService;
static HashMap org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore;
@Autowired
public CronController(CronService cronService) {
byte var2 = 0;
Logging.recordEvent(8659304);
Logging.recordEvent(cronService, 8659305);
Logging.recordEvent(8659306);
Logging.recordEvent(8659307);
int var4 = 8659307;
super();
var2 = 0;
Logging.recordEvent(8659308);
Logging.recordEvent(this, 8659309);
try {
Logging.recordEvent(8659310);
Logging.recordEvent(cronService, 8659311);
Logging.recordEvent(this, 8659312);
Logging.recordEvent(cronService, 8659313);
var4 = 8659312;
this.cronService = cronService;
var2 = 0;
Logging.recordEvent(8659314);
Logging.recordEvent(8659315);
} catch (Throwable var3) {
Logging.recordEvent(var2, 8659316);
Logging.recordEvent(var3, 8659317);
Logging.recordEvent(var3, 8659318);
throw var3;
}
}
public Mono<String> Unlogged$Probed$$cronHello() {
byte var1 = 0;
try {
Logging.recordEvent(this, 8659321);
Logging.recordEvent(8659322);
Logging.recordEvent(this, 8659323);
int var4 = 8659323;
CronService var10000 = this.cronService;
var1 = 0;
Logging.recordEvent(var10000, 8659324);
Logging.recordEvent(var10000, 8659325);
var4 = 8659325;
Mono var5 = var10000.getCount();
var1 = 0;
var5 = Logging.recordEvent(var5, 8659326);
Logging.recordEvent(8659327);
Function var10001 = (count) -> {
org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore.put("lambda$cronHello$0", (Long)org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore.get("lambda$cronHello$0") + 1L);
return Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore.get("lambda$cronHello$0"), 1L) ? Unlogged$Probed$$lambda$cronHello$0(count) : "Hello Cron: " + count;
};
Logging.recordEvent(var10001, 8659328);
Function var2 = var10001;
Logging.recordEvent(var5, 8659329);
Logging.recordEvent(var2, 8659330);
var4 = 8659329;
var5 = var5.map(var2);
var1 = 0;
return Logging.recordEvent(Logging.recordEvent(var5, 8659331), 8659332);
} catch (Throwable var3) {
Logging.recordEvent(var1, 8659333);
Logging.recordEvent(var3, 8659334);
Logging.recordEvent(var3, 8659335);
throw var3;
}
}
@GetMapping({"/hello"})
public Mono<String> cronHello() {
org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore.put("cronHello", (Long)org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore.get("cronHello") + 1L);
return Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore.get("cronHello"), 1L) ? this.Unlogged$Probed$$cronHello() : this.cronService.getCount().map((count) -> {
org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore.put("lambda$cronHello$0", (Long)org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore.get("lambda$cronHello$0") + 1L);
return Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore.get("lambda$cronHello$0"), 1L) ? Unlogged$Probed$$lambda$cronHello$0(count) : "Hello Cron: " + count;
});
}
// $FF: synthetic method
private static String Unlogged$Probed$$lambda$cronHello$0(Integer count) {
byte var1 = 0;
try {
Logging.recordEvent(8659338);
Logging.recordEvent(count, 8659339);
Logging.recordEvent(8659340);
Logging.recordEvent(count, 8659341);
Logging.recordEvent(8659342);
Logging.recordEvent(count, 8659343);
String var10000 = "Hello Cron: " + count;
Logging.recordEvent(var10000, 8659344);
Logging.recordEvent(var10000, 8659345);
return var10000;
} catch (Throwable var3) {
Logging.recordEvent(var1, 8659346);
Logging.recordEvent(var3, 8659347);
Logging.recordEvent(var3, 8659348);
throw var3;
}
}
static {
Runtime.registerClass("eNrNV1tzGzUUdtqQNM1wKw+FJwYmMzhl6735thgzBDeZenCcTlPCMDxpJa2zyXpldmUnLtdCuUO5Dvwi/gLwCL+ESruyo6zX6yQwTDyzY+1+53z6JJ1zJOVyv/2Vy+WqJOgU+r5HOh2MCmEvcP3OAbYdr3+IcJcUIPFpQDwPB4VGQPzG+JX5PnX8S2EPDICgVEeU6gSlekSpTlAutEnQBR5r5avILlrYMa0i+0OlMkaObhnlIiiXKiYCCGLdsA1NZ7brLQIQDl7lAuBL/6L70e8JzqR6wO+oW/YehjT6qub4nC3O/Z67/5zzj/gJjyfjvzHekdheZM88exab9bVw6EPJbFcym0uhcSX8AheWwPeED/c1Uvz3xbeLvHvRxg3geXeGPVy/jSF2BzhoE9r0XeoCz72LkdL0Qxr0IXWJX2+2d7ZeX9++td5orrWUrQMfB/Xk5Cht0MX1l11G8YpyA4ewnl/dkUR4kogl0X6Gi7gFAuzTerVcskytokSaZMeu5HgxZfQ+e7nCnkemjJ4InI/8uvC3ol5aM4IkxMHAhTiKkO24XZOIe4L4kuiUEz+IJ+es0adsuNhD0UzCo06V/0LtO5LaK+debVRZ2HN5yqKGAl8WWcXxhYnQocLqUcE0n2DpS/hySmgNJHwhgf/B8IOM/Of44ez852bDRP4nu7nLXq5OyW+Ovytwnh2Pneul5Wrfk9Q+fu7Vvi/UzosKwtX+ItXOTt8DQUqx3GnevvPGuFieXkNcTjuYNkjfp6OC2gowgJQEbCoCrPb6tueGu2w6NolPZNUfSKqXhOpSstgaJTFDJyT9UJDyQpuPw3Du78mR33irvbbZbMQDAL2eNxyrj/aMPnU91en7kY+6IRo15TVCKOMCPWlrcf0B2cdqC3RtBDYxBU6kdHhkzD7uElTvpmFxt60JutjnJvCRh8OVFiH7/V5NMtumfIFq0xz5pJ0NjLvM9l2dRPnCbbsUS3O0FnRCjYdVgUS7L4umAgi7BU5x3EpPsYp1HLczprBJAfCRFADXUurUPYEvSLny66lzJSMa45jqgp4iL+2UgDpxsnwsyb4kZNcnksViwhE+rOsiabK6lsg/kcinZ6J1uky8L0gXRYpz0udPxfCpYFhK2Rk5/pmEL6cs9ecSntwZ/2T4Fxk7I8e/nL0zcrOvMk7GHP8642TM8W8ydk6OfyvwC+JsyJf/aWl9oyxs+hR3cFCT/B5Ie9ioFN6bUQq7YB+zLQsC+qZLd1krpMCnoTJRpUb9rU6WpKwiGZvEPWxMK5NTNPzfJVOYv91K3iJOVf64ZYFbFmI+aYG+kxZoVQTGSRb2e8nvWkpA/SBtrKPMu5rkFaOT3H6UqkAy3Tj+k4Qvp3T7s4RL6cZlisMq+x7fvVirkj/LoYff1qJEmXKjz0PHgRBXzbJpgopeKlsVbGhlDWKkmRXL0QCsQAQcfVwmWHngx7Gb2PP4JezZmeeXzO7Z5RAZEJoIakbV0ivVom6ZQNNhqWRB22airIqBARhPG7vneNHBYWWsYkVjX184YbKxab6coQdVbVAydABhxcIlTbeKbGosBLDGJsfWyg6qloGJjIfAifT4", "eNpjaFFMZ2hRzATiHCAuBuIyIK4A4jogbgLiZiBuAeJ2IO4E4m4gngjEUwDyrREQ");
org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore = new HashMap();
org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore.put("lambda$cronHello$0", 0L);
org$unlogged$springwebfluxdemo$controller$CronController$unlogged$$mapStore.put("cronHello", 0L);
}
}Decompiled FluxOpsController ->
package org.unlogged.springwebfluxdemo.controller;
import io.unlogged.Runtime;
import io.unlogged.logging.Logging;
import java.io.PrintStream;
import java.time.Duration;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Objects;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.BiFunction;
import java.util.function.Consumer;
import java.util.function.Function;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.unlogged.springwebfluxdemo.controller.FluxOpsController.1;
import org.unlogged.springwebfluxdemo.controller.FluxOpsController.2;
import reactor.core.Disposable;
import reactor.core.publisher.ConnectableFlux;
import reactor.core.publisher.Flux;
import reactor.core.publisher.FluxSink;
import reactor.core.publisher.ParallelFlux;
import reactor.core.scheduler.Scheduler;
import reactor.core.scheduler.Schedulers;
import reactor.util.function.Tuple4;
@RestController
@RequestMapping({"/flux"})
public class FluxOpsController {
static HashMap org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore;
public FluxOpsController() {
byte var1 = 0;
Logging.recordEvent(8652955);
Logging.recordEvent(8652956);
Logging.recordEvent(8652957);
int var3 = 8652957;
super();
var1 = 0;
Logging.recordEvent(8652958);
Logging.recordEvent(this, 8652959);
try {
Logging.recordEvent(8652960);
} catch (Throwable var2) {
Logging.recordEvent(var1, 8652961);
Logging.recordEvent(var2, 8652962);
Logging.recordEvent(var2, 8652963);
throw var2;
}
}
public List<Integer> Unlogged$Probed$$fluxListSubscribe() {
byte var1 = 0;
try {
Logging.recordEvent(this, 8652966);
Logging.recordEvent(8652967);
Logging.recordEvent(8652968);
Logging.recordEvent(8652969);
int var24 = 8652969;
ArrayList var10000 = new ArrayList();
var1 = 0;
Logging.recordEvent(8652970);
Logging.recordEvent(var10000, 8652971);
Logging.recordEvent(var10000, 8652972);
List<Integer> elements = var10000;
Logging.recordEvent(8652973);
Logging.recordEvent(8, 8652974);
Integer[] var25 = new Integer[8];
Logging.recordEvent(var25, 8652975);
byte var3 = 1;
Logging.recordEvent(8652976);
Logging.recordEvent(var3, 8652977);
var24 = 8652976;
Integer var10003 = Integer.valueOf(var3);
var1 = 0;
Logging.recordEvent(var10003, 8652978);
Integer var4 = var10003;
Logging.recordArrayStore(var25, 0, var4, 8652979);
var24 = 8652979;
var25[0] = var4;
var1 = 0;
byte var5 = 2;
Logging.recordEvent(8652982);
Logging.recordEvent(var5, 8652983);
var24 = 8652982;
var10003 = Integer.valueOf(var5);
var1 = 0;
Logging.recordEvent(var10003, 8652984);
Integer var6 = var10003;
Logging.recordArrayStore(var25, 1, var6, 8652985);
var24 = 8652985;
var25[1] = var6;
var1 = 0;
byte var7 = 3;
Logging.recordEvent(8652988);
Logging.recordEvent(var7, 8652989);
var24 = 8652988;
var10003 = Integer.valueOf(var7);
var1 = 0;
Logging.recordEvent(var10003, 8652990);
Integer var8 = var10003;
Logging.recordArrayStore(var25, 2, var8, 8652991);
var24 = 8652991;
var25[2] = var8;
var1 = 0;
byte var9 = 4;
Logging.recordEvent(8652994);
Logging.recordEvent(var9, 8652995);
var24 = 8652994;
var10003 = Integer.valueOf(var9);
var1 = 0;
Logging.recordEvent(var10003, 8652996);
Integer var10 = var10003;
Logging.recordArrayStore(var25, 3, var10, 8652997);
var24 = 8652997;
var25[3] = var10;
var1 = 0;
byte var11 = 50;
Logging.recordEvent(8653000);
Logging.recordEvent(var11, 8653001);
var24 = 8653000;
var10003 = Integer.valueOf(var11);
var1 = 0;
Logging.recordEvent(var10003, 8653002);
Integer var12 = var10003;
Logging.recordArrayStore(var25, 4, var12, 8653003);
var24 = 8653003;
var25[4] = var12;
var1 = 0;
byte var13 = 100;
Logging.recordEvent(8653006);
Logging.recordEvent(var13, 8653007);
var24 = 8653006;
var10003 = Integer.valueOf(var13);
var1 = 0;
Logging.recordEvent(var10003, 8653008);
Integer var14 = var10003;
Logging.recordArrayStore(var25, 5, var14, 8653009);
var24 = 8653009;
var25[5] = var14;
var1 = 0;
short var15 = 150;
Logging.recordEvent(8653012);
Logging.recordEvent(var15, 8653013);
var24 = 8653012;
var10003 = Integer.valueOf(var15);
var1 = 0;
Logging.recordEvent(var10003, 8653014);
Integer var16 = var10003;
Logging.recordArrayStore(var25, 6, var16, 8653015);
var24 = 8653015;
var25[6] = var16;
var1 = 0;
short var17 = 200;
Logging.recordEvent(8653018);
Logging.recordEvent(var17, 8653019);
var24 = 8653018;
var10003 = Integer.valueOf(var17);
var1 = 0;
Logging.recordEvent(var10003, 8653020);
Integer var18 = var10003;
Logging.recordArrayStore(var25, 7, var18, 8653021);
var24 = 8653021;
var25[7] = var18;
var1 = 0;
Integer[] var19 = var25;
Logging.recordEvent(8653024);
Logging.recordEvent(var19, 8653025);
var24 = 8653024;
Flux var26 = Flux.just(var19);
var1 = 0;
var26 = Logging.recordEvent(var26, 8653026);
Logging.recordEvent(8653027);
Logging.recordEvent(elements, 8653028);
Logging.recordEvent(8653029);
Logging.recordEvent(this, 8653030);
Logging.recordEvent(elements, 8653031);
var24 = 8653029;
1 var10001 = new 1(this, elements);
var1 = 0;
Logging.recordEvent(8653032);
Logging.recordEvent(var10001, 8653033);
Logging.recordEvent(8653034);
1 var22 = var10001;
Logging.recordEvent(var26, 8653035);
Logging.recordEvent(var22, 8653036);
var24 = 8653035;
var26.subscribe(var22);
var1 = 0;
Logging.recordEvent(8653037);
Logging.recordEvent(8653038);
Logging.recordEvent(elements, 8653039);
Logging.recordEvent(elements, 8653040);
return elements;
} catch (Throwable var23) {
Logging.recordEvent(var1, 8653041);
Logging.recordEvent(var23, 8653042);
Logging.recordEvent(var23, 8653043);
throw var23;
}
}
public List<Integer> fluxListSubscribe() {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("fluxListSubscribe", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("fluxListSubscribe") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("fluxListSubscribe"), 1L)) {
return this.Unlogged$Probed$$fluxListSubscribe();
} else {
List<Integer> elements = new ArrayList();
Flux.just(new Integer[]{1, 2, 3, 4, 50, 100, 150, 200}).subscribe(new 1(this, elements));
return elements;
}
}
public void Unlogged$Probed$$connectableFluxExample() {
byte var1 = 0;
try {
Logging.recordEvent(this, 8653046);
Logging.recordEvent(8653047);
Logging.recordEvent(8653048);
byte var2 = 5;
Logging.recordEvent(8653049);
Logging.recordEvent(var2, 8653050);
int var12 = 8653049;
AtomicInteger var10000 = new AtomicInteger(var2);
var1 = 0;
Logging.recordEvent(8653051);
Logging.recordEvent(var10000, 8653052);
Logging.recordEvent(var10000, 8653053);
AtomicInteger triesLift = var10000;
Logging.recordEvent(8653054);
Logging.recordEvent(triesLift, 8653055);
Logging.recordEvent(8653056);
Logging.recordEvent(triesLift, 8653057);
Consumer var13 = (fluxSink) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$connectableFluxExample$0", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$connectableFluxExample$0") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$connectableFluxExample$0"), 1L)) {
Unlogged$Probed$$lambda$connectableFluxExample$0(triesLift, fluxSink);
} else {
while(triesLift.get() > 0) {
triesLift.getAndDecrement();
fluxSink.next(System.currentTimeMillis());
}
}
};
Logging.recordEvent(var13, 8653058);
Consumer var5 = var13;
Logging.recordEvent(8653059);
Logging.recordEvent(var5, 8653060);
var12 = 8653059;
Flux var14 = Flux.create(var5);
var1 = 0;
var14 = Logging.recordEvent(var14, 8653061);
Logging.recordEvent(8653062);
Logging.recordEvent(var14, 8653063);
var12 = 8653063;
ConnectableFlux var15 = var14.publish();
var1 = 0;
Logging.recordEvent(var15, 8653064);
Logging.recordEvent(var15, 8653065);
ConnectableFlux<Object> publish = var15;
Logging.recordEvent(8653066);
Logging.recordEvent(publish, 8653067);
PrintStream var10001 = System.out;
Logging.recordEvent(var10001, 8653068);
PrintStream var7 = var10001;
Logging.recordEvent(8653069);
Logging.recordEvent(var7, 8653070);
var12 = 8653069;
Object var10002 = Objects.requireNonNull(var7);
var1 = 0;
Logging.recordEvent(var10002, 8653071);
Logging.recordEvent(8653072);
PrintStream var8 = var10001;
Logging.recordEvent(var8, 8653073);
Consumer var16 = var8::println;
Logging.recordEvent(var16, 8653074);
Consumer var9 = var16;
Logging.recordEvent(publish, 8653075);
Logging.recordEvent(var9, 8653076);
var12 = 8653075;
Disposable var17 = publish.subscribe(var9);
var1 = 0;
Logging.recordEvent(var17, 8653077);
Logging.recordEvent(8653078);
Logging.recordEvent(publish, 8653079);
Logging.recordEvent(8653080);
var16 = FluxOpsController::pingOnSubscribe;
Logging.recordEvent(var16, 8653081);
Consumer var10 = var16;
Logging.recordEvent(publish, 8653082);
Logging.recordEvent(var10, 8653083);
var12 = 8653082;
var17 = publish.subscribe(var10);
var1 = 0;
Logging.recordEvent(var17, 8653084);
Logging.recordEvent(8653085);
Logging.recordEvent(publish, 8653086);
Logging.recordEvent(publish, 8653087);
var12 = 8653087;
var17 = publish.connect();
var1 = 0;
Logging.recordEvent(var17, 8653088);
Logging.recordEvent(8653089);
Logging.recordEvent(8653090);
} catch (Throwable var11) {
Logging.recordEvent(var1, 8653091);
Logging.recordEvent(var11, 8653092);
Logging.recordEvent(var11, 8653093);
throw var11;
}
}
@RequestMapping({"/connectable"})
public void connectableFluxExample() {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("connectableFluxExample", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("connectableFluxExample") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("connectableFluxExample"), 1L)) {
this.Unlogged$Probed$$connectableFluxExample();
} else {
AtomicInteger triesLift = new AtomicInteger(5);
ConnectableFlux<Object> publish = Flux.create((fluxSink) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$connectableFluxExample$0", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$connectableFluxExample$0") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$connectableFluxExample$0"), 1L)) {
Unlogged$Probed$$lambda$connectableFluxExample$0(triesLift, fluxSink);
} else {
while(triesLift.get() > 0) {
triesLift.getAndDecrement();
fluxSink.next(System.currentTimeMillis());
}
}
}).publish();
PrintStream var10001 = System.out;
Objects.requireNonNull(var10001);
publish.subscribe(var10001::println);
publish.subscribe(FluxOpsController::pingOnSubscribe);
publish.connect();
}
}
public Flux<String> Unlogged$Probed$$getFluxString() {
byte var1 = 0;
try {
Logging.recordEvent(this, 8653096);
Logging.recordEvent(8653097);
String var2 = "stringInput";
Logging.recordEvent(8653098);
Logging.recordEvent(var2, 8653099);
int var5 = 8653098;
Flux var10000 = Flux.just(var2);
var1 = 0;
var10000 = Logging.recordEvent(var10000, 8653100);
Logging.recordEvent(var10000, 8653101);
Flux<String> fluxString = var10000;
Logging.recordEvent(8653102);
Logging.recordEvent(fluxString, 8653103);
return Logging.recordEvent(fluxString, 8653104);
} catch (Throwable var4) {
Logging.recordEvent(var1, 8653105);
Logging.recordEvent(var4, 8653106);
Logging.recordEvent(var4, 8653107);
throw var4;
}
}
@RequestMapping({"/string"})
public Flux<String> getFluxString() {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("getFluxString", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("getFluxString") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("getFluxString"), 1L)) {
return this.Unlogged$Probed$$getFluxString();
} else {
Flux<String> fluxString = Flux.just("stringInput");
return fluxString;
}
}
private static void Unlogged$Probed$$pingOnSubscribe(Object o) {
byte var1 = 0;
try {
Logging.recordEvent(8653110);
Logging.recordEvent(var0, 8653111);
Logging.recordEvent(8653112);
PrintStream var10000 = System.out;
Logging.recordEvent(var10000, 8653113);
String var2 = "PING";
Logging.recordEvent(var10000, 8653114);
Logging.recordEvent(var2, 8653115);
int var4 = 8653114;
var10000.println(var2);
var1 = 0;
Logging.recordEvent(8653116);
Logging.recordEvent(8653117);
Logging.recordEvent(8653118);
} catch (Throwable var3) {
Logging.recordEvent(var1, 8653119);
Logging.recordEvent(var3, 8653120);
Logging.recordEvent(var3, 8653121);
throw var3;
}
}
private static void pingOnSubscribe(Object o) {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("pingOnSubscribe", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("pingOnSubscribe") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("pingOnSubscribe"), 1L)) {
Unlogged$Probed$$pingOnSubscribe(var0);
} else {
System.out.println("PING");
}
}
public int Unlogged$Probed$$fluxThrottling() {
byte var1 = 0;
try {
Logging.recordEvent(this, 8653124);
Logging.recordEvent(8653125);
Logging.recordEvent(8653126);
byte var2 = 5;
Logging.recordEvent(8653127);
Logging.recordEvent(var2, 8653128);
int var14 = 8653127;
AtomicInteger var10000 = new AtomicInteger(var2);
var1 = 0;
Logging.recordEvent(8653129);
Logging.recordEvent(var10000, 8653130);
Logging.recordEvent(var10000, 8653131);
AtomicInteger triesLift = var10000;
Logging.recordEvent(8653132);
Logging.recordEvent(triesLift, 8653133);
Logging.recordEvent(8653134);
Logging.recordEvent(triesLift, 8653135);
Consumer var15 = (fluxSink) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$fluxThrottling$1", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$fluxThrottling$1") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$fluxThrottling$1"), 1L)) {
Unlogged$Probed$$lambda$fluxThrottling$1(triesLift, fluxSink);
} else {
while(triesLift.get() > 0) {
triesLift.getAndDecrement();
int var10001 = triesLift.get();
fluxSink.next("Print : Counter : " + var10001 + " - " + System.currentTimeMillis());
}
}
};
Logging.recordEvent(var15, 8653136);
Consumer var5 = var15;
Logging.recordEvent(8653137);
Logging.recordEvent(var5, 8653138);
var14 = 8653137;
Flux var16 = Flux.create(var5);
var1 = 0;
var16 = Logging.recordEvent(var16, 8653139);
Logging.recordEvent(8653140);
long var6 = 1L;
Logging.recordEvent(8653141);
Logging.recordEvent(var6, 8653142);
var14 = 8653141;
Duration var10001 = Duration.ofSeconds(var6);
var1 = 0;
Logging.recordEvent(var10001, 8653143);
Duration var8 = var10001;
Logging.recordEvent(var16, 8653144);
Logging.recordEvent(var8, 8653145);
var14 = 8653144;
var16 = var16.sample(var8);
var1 = 0;
var16 = Logging.recordEvent(var16, 8653146);
Logging.recordEvent(8653147);
Logging.recordEvent(var16, 8653148);
var14 = 8653148;
ConnectableFlux var19 = var16.publish();
var1 = 0;
Logging.recordEvent(var19, 8653149);
Logging.recordEvent(var19, 8653150);
ConnectableFlux<Object> publish = var19;
Logging.recordEvent(8653151);
Logging.recordEvent(publish, 8653152);
PrintStream var17 = System.out;
Logging.recordEvent(var17, 8653153);
PrintStream var10 = var17;
Logging.recordEvent(8653154);
Logging.recordEvent(var10, 8653155);
var14 = 8653154;
Object var10002 = Objects.requireNonNull(var10);
var1 = 0;
Logging.recordEvent(var10002, 8653156);
Logging.recordEvent(8653157);
PrintStream var11 = var17;
Logging.recordEvent(var11, 8653158);
Consumer var18 = var11::println;
Logging.recordEvent(var18, 8653159);
Consumer var12 = var18;
Logging.recordEvent(publish, 8653160);
Logging.recordEvent(var12, 8653161);
var14 = 8653160;
Disposable var20 = publish.subscribe(var12);
var1 = 0;
Logging.recordEvent(var20, 8653162);
Logging.recordEvent(8653163);
Logging.recordEvent(publish, 8653164);
Logging.recordEvent(publish, 8653165);
var14 = 8653165;
var20 = publish.connect();
var1 = 0;
Logging.recordEvent(var20, 8653166);
Logging.recordEvent(8653167);
Logging.recordEvent(triesLift, 8653168);
Logging.recordEvent(triesLift, 8653169);
var14 = 8653169;
int var21 = triesLift.get();
var1 = 0;
Logging.recordEvent(var21, 8653170);
Logging.recordEvent(var21, 8653171);
return var21;
} catch (Throwable var13) {
Logging.recordEvent(var1, 8653172);
Logging.recordEvent(var13, 8653173);
Logging.recordEvent(var13, 8653174);
throw var13;
}
}
@RequestMapping({"/throttling"})
public int fluxThrottling() {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("fluxThrottling", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("fluxThrottling") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("fluxThrottling"), 1L)) {
return this.Unlogged$Probed$$fluxThrottling();
} else {
AtomicInteger triesLift = new AtomicInteger(5);
ConnectableFlux<Object> publish = Flux.create((fluxSink) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$fluxThrottling$1", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$fluxThrottling$1") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$fluxThrottling$1"), 1L)) {
Unlogged$Probed$$lambda$fluxThrottling$1(triesLift, fluxSink);
} else {
while(triesLift.get() > 0) {
triesLift.getAndDecrement();
int var10001 = triesLift.get();
fluxSink.next("Print : Counter : " + var10001 + " - " + System.currentTimeMillis());
}
}
}).sample(Duration.ofSeconds(1L)).publish();
PrintStream var10001 = System.out;
Objects.requireNonNull(var10001);
publish.subscribe(var10001::println);
publish.connect();
return triesLift.get();
}
}
public List<Integer> Unlogged$Probed$$concurrent() throws InterruptedException {
byte var1 = 0;
try {
Logging.recordEvent(this, 8653177);
Logging.recordEvent(8653178);
Logging.recordEvent(8653179);
Logging.recordEvent(8653180);
int var20 = 8653180;
ArrayList var10000 = new ArrayList();
var1 = 0;
Logging.recordEvent(8653181);
Logging.recordEvent(var10000, 8653182);
Logging.recordEvent(var10000, 8653183);
List<Integer> elements = var10000;
Logging.recordEvent(8653184);
Logging.recordEvent(4, 8653185);
Integer[] var21 = new Integer[4];
Logging.recordEvent(var21, 8653186);
byte var3 = 1;
Logging.recordEvent(8653187);
Logging.recordEvent(var3, 8653188);
var20 = 8653187;
Integer var10003 = Integer.valueOf(var3);
var1 = 0;
Logging.recordEvent(var10003, 8653189);
Integer var4 = var10003;
Logging.recordArrayStore(var21, 0, var4, 8653190);
var20 = 8653190;
var21[0] = var4;
var1 = 0;
byte var5 = 2;
Logging.recordEvent(8653193);
Logging.recordEvent(var5, 8653194);
var20 = 8653193;
var10003 = Integer.valueOf(var5);
var1 = 0;
Logging.recordEvent(var10003, 8653195);
Integer var6 = var10003;
Logging.recordArrayStore(var21, 1, var6, 8653196);
var20 = 8653196;
var21[1] = var6;
var1 = 0;
byte var7 = 3;
Logging.recordEvent(8653199);
Logging.recordEvent(var7, 8653200);
var20 = 8653199;
var10003 = Integer.valueOf(var7);
var1 = 0;
Logging.recordEvent(var10003, 8653201);
Integer var8 = var10003;
Logging.recordArrayStore(var21, 2, var8, 8653202);
var20 = 8653202;
var21[2] = var8;
var1 = 0;
byte var9 = 4;
Logging.recordEvent(8653205);
Logging.recordEvent(var9, 8653206);
var20 = 8653205;
var10003 = Integer.valueOf(var9);
var1 = 0;
Logging.recordEvent(var10003, 8653207);
Integer var10 = var10003;
Logging.recordArrayStore(var21, 3, var10, 8653208);
var20 = 8653208;
var21[3] = var10;
var1 = 0;
Integer[] var11 = var21;
Logging.recordEvent(8653211);
Logging.recordEvent(var11, 8653212);
var20 = 8653211;
Flux var22 = Flux.just(var11);
var1 = 0;
var22 = Logging.recordEvent(var22, 8653213);
Logging.recordEvent(8653214);
Logging.recordEvent(var22, 8653215);
var20 = 8653215;
var22 = var22.log();
var1 = 0;
var22 = Logging.recordEvent(var22, 8653216);
Logging.recordEvent(8653217);
Function var10001 = (i) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$concurrent$2", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$concurrent$2") + 1L);
return Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$concurrent$2"), 1L) ? Unlogged$Probed$$lambda$concurrent$2(i) : i * 2;
};
Logging.recordEvent(var10001, 8653218);
Logging.recordEvent(8653219);
Function var12 = var10001;
Logging.recordEvent(var22, 8653220);
Logging.recordEvent(var12, 8653221);
var20 = 8653220;
var22 = var22.map(var12);
var1 = 0;
var22 = Logging.recordEvent(var22, 8653222);
Logging.recordEvent(8653223);
Logging.recordEvent(8653224);
var20 = 8653224;
Scheduler var23 = Schedulers.parallel();
var1 = 0;
Logging.recordEvent(var23, 8653225);
Scheduler var13 = var23;
Logging.recordEvent(var22, 8653226);
Logging.recordEvent(var13, 8653227);
var20 = 8653226;
var22 = var22.subscribeOn(var13);
var1 = 0;
var22 = Logging.recordEvent(var22, 8653228);
Logging.recordEvent(elements, 8653229);
Logging.recordEvent(8653230);
Logging.recordEvent(8653231);
Logging.recordEvent(elements, 8653232);
var20 = 8653231;
Object var10002 = Objects.requireNonNull(elements);
var1 = 0;
Logging.recordEvent(var10002, 8653233);
Logging.recordEvent(8653234);
Logging.recordEvent(elements, 8653235);
Consumer var24 = elements::add;
Logging.recordEvent(var24, 8653236);
Consumer var16 = var24;
Logging.recordEvent(var22, 8653237);
Logging.recordEvent(var16, 8653238);
var20 = 8653237;
Disposable var25 = var22.subscribe(var16);
var1 = 0;
Logging.recordEvent(var25, 8653239);
Logging.recordEvent(8653240);
long var17 = 200L;
Logging.recordEvent(8653241);
Logging.recordEvent(var17, 8653242);
var20 = 8653241;
Thread.sleep(var17);
var1 = 0;
Logging.recordEvent(8653243);
Logging.recordEvent(8653244);
Logging.recordEvent(elements, 8653245);
Logging.recordEvent(elements, 8653246);
return elements;
} catch (Throwable var19) {
Logging.recordEvent(var1, 8653247);
Logging.recordEvent(var19, 8653248);
Logging.recordEvent(var19, 8653249);
throw var19;
}
}
@RequestMapping({"/concurrent"})
public List<Integer> concurrent() throws InterruptedException {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("concurrent", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("concurrent") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("concurrent"), 1L)) {
return this.Unlogged$Probed$$concurrent();
} else {
List<Integer> elements = new ArrayList();
Flux var10000 = Flux.just(new Integer[]{1, 2, 3, 4}).log().map((i) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$concurrent$2", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$concurrent$2") + 1L);
return Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$concurrent$2"), 1L) ? Unlogged$Probed$$lambda$concurrent$2(i) : i * 2;
}).subscribeOn(Schedulers.parallel());
Objects.requireNonNull(elements);
var10000.subscribe(elements::add);
Thread.sleep(200L);
return elements;
}
}
public List<Integer> Unlogged$Probed$$backPressure1() {
byte var1 = 0;
try {
Logging.recordEvent(this, 8653252);
Logging.recordEvent(8653253);
Logging.recordEvent(8653254);
Logging.recordEvent(8653255);
int var16 = 8653255;
ArrayList var10000 = new ArrayList();
var1 = 0;
Logging.recordEvent(8653256);
Logging.recordEvent(var10000, 8653257);
Logging.recordEvent(var10000, 8653258);
List<Integer> elements = var10000;
Logging.recordEvent(8653259);
Logging.recordEvent(4, 8653260);
Integer[] var17 = new Integer[4];
Logging.recordEvent(var17, 8653261);
byte var3 = 1;
Logging.recordEvent(8653262);
Logging.recordEvent(var3, 8653263);
var16 = 8653262;
Integer var10003 = Integer.valueOf(var3);
var1 = 0;
Logging.recordEvent(var10003, 8653264);
Integer var4 = var10003;
Logging.recordArrayStore(var17, 0, var4, 8653265);
var16 = 8653265;
var17[0] = var4;
var1 = 0;
byte var5 = 2;
Logging.recordEvent(8653268);
Logging.recordEvent(var5, 8653269);
var16 = 8653268;
var10003 = Integer.valueOf(var5);
var1 = 0;
Logging.recordEvent(var10003, 8653270);
Integer var6 = var10003;
Logging.recordArrayStore(var17, 1, var6, 8653271);
var16 = 8653271;
var17[1] = var6;
var1 = 0;
byte var7 = 3;
Logging.recordEvent(8653274);
Logging.recordEvent(var7, 8653275);
var16 = 8653274;
var10003 = Integer.valueOf(var7);
var1 = 0;
Logging.recordEvent(var10003, 8653276);
Integer var8 = var10003;
Logging.recordArrayStore(var17, 2, var8, 8653277);
var16 = 8653277;
var17[2] = var8;
var1 = 0;
byte var9 = 4;
Logging.recordEvent(8653280);
Logging.recordEvent(var9, 8653281);
var16 = 8653280;
var10003 = Integer.valueOf(var9);
var1 = 0;
Logging.recordEvent(var10003, 8653282);
Integer var10 = var10003;
Logging.recordArrayStore(var17, 3, var10, 8653283);
var16 = 8653283;
var17[3] = var10;
var1 = 0;
Integer[] var11 = var17;
Logging.recordEvent(8653286);
Logging.recordEvent(var11, 8653287);
var16 = 8653286;
Flux var18 = Flux.just(var11);
var1 = 0;
var18 = Logging.recordEvent(var18, 8653288);
Logging.recordEvent(8653289);
Logging.recordEvent(var18, 8653290);
var16 = 8653290;
var18 = var18.log();
var1 = 0;
var18 = Logging.recordEvent(var18, 8653291);
Logging.recordEvent(8653292);
Logging.recordEvent(elements, 8653293);
Logging.recordEvent(8653294);
Logging.recordEvent(this, 8653295);
Logging.recordEvent(elements, 8653296);
var16 = 8653294;
2 var10001 = new 2(this, elements);
var1 = 0;
Logging.recordEvent(8653297);
Logging.recordEvent(var10001, 8653298);
Logging.recordEvent(8653299);
2 var14 = var10001;
Logging.recordEvent(var18, 8653300);
Logging.recordEvent(var14, 8653301);
var16 = 8653300;
var18.subscribe(var14);
var1 = 0;
Logging.recordEvent(8653302);
Logging.recordEvent(8653303);
Logging.recordEvent(elements, 8653304);
Logging.recordEvent(elements, 8653305);
return elements;
} catch (Throwable var15) {
Logging.recordEvent(var1, 8653306);
Logging.recordEvent(var15, 8653307);
Logging.recordEvent(var15, 8653308);
throw var15;
}
}
@RequestMapping({"/backpressure/1"})
public List<Integer> backPressure1() {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("backPressure1", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("backPressure1") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("backPressure1"), 1L)) {
return this.Unlogged$Probed$$backPressure1();
} else {
List<Integer> elements = new ArrayList();
Flux.just(new Integer[]{1, 2, 3, 4}).log().subscribe(new 2(this, elements));
return elements;
}
}
public List<String> Unlogged$Probed$$combineStreams() {
byte var1 = 0;
try {
Logging.recordEvent(this, 8653311);
Logging.recordEvent(8653312);
Logging.recordEvent(8653313);
Logging.recordEvent(8653314);
int var20 = 8653314;
ArrayList var10000 = new ArrayList();
var1 = 0;
Logging.recordEvent(8653315);
Logging.recordEvent(var10000, 8653316);
Logging.recordEvent(var10000, 8653317);
List<String> elements = var10000;
Logging.recordEvent(8653318);
Logging.recordEvent(4, 8653319);
Integer[] var21 = new Integer[4];
Logging.recordEvent(var21, 8653320);
byte var3 = 1;
Logging.recordEvent(8653321);
Logging.recordEvent(var3, 8653322);
var20 = 8653321;
Integer var10003 = Integer.valueOf(var3);
var1 = 0;
Logging.recordEvent(var10003, 8653323);
Integer var4 = var10003;
Logging.recordArrayStore(var21, 0, var4, 8653324);
var20 = 8653324;
var21[0] = var4;
var1 = 0;
byte var5 = 2;
Logging.recordEvent(8653327);
Logging.recordEvent(var5, 8653328);
var20 = 8653327;
var10003 = Integer.valueOf(var5);
var1 = 0;
Logging.recordEvent(var10003, 8653329);
Integer var6 = var10003;
Logging.recordArrayStore(var21, 1, var6, 8653330);
var20 = 8653330;
var21[1] = var6;
var1 = 0;
byte var7 = 3;
Logging.recordEvent(8653333);
Logging.recordEvent(var7, 8653334);
var20 = 8653333;
var10003 = Integer.valueOf(var7);
var1 = 0;
Logging.recordEvent(var10003, 8653335);
Integer var8 = var10003;
Logging.recordArrayStore(var21, 2, var8, 8653336);
var20 = 8653336;
var21[2] = var8;
var1 = 0;
byte var9 = 4;
Logging.recordEvent(8653339);
Logging.recordEvent(var9, 8653340);
var20 = 8653339;
var10003 = Integer.valueOf(var9);
var1 = 0;
Logging.recordEvent(var10003, 8653341);
Integer var10 = var10003;
Logging.recordArrayStore(var21, 3, var10, 8653342);
var20 = 8653342;
var21[3] = var10;
var1 = 0;
Integer[] var11 = var21;
Logging.recordEvent(8653345);
Logging.recordEvent(var11, 8653346);
var20 = 8653345;
Flux var22 = Flux.just(var11);
var1 = 0;
var22 = Logging.recordEvent(var22, 8653347);
Logging.recordEvent(8653348);
Logging.recordEvent(var22, 8653349);
var20 = 8653349;
var22 = var22.log();
var1 = 0;
var22 = Logging.recordEvent(var22, 8653350);
Logging.recordEvent(8653351);
Function var10001 = (i) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$combineStreams$3", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$combineStreams$3") + 1L);
return Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$combineStreams$3"), 1L) ? Unlogged$Probed$$lambda$combineStreams$3(i) : i * 2;
};
Logging.recordEvent(var10001, 8653352);
Logging.recordEvent(8653353);
Function var12 = var10001;
Logging.recordEvent(var22, 8653354);
Logging.recordEvent(var12, 8653355);
var20 = 8653354;
var22 = var22.map(var12);
var1 = 0;
var22 = Logging.recordEvent(var22, 8653356);
Logging.recordEvent(8653357);
int var13 = Integer.MAX_VALUE;
byte var14 = 0;
Logging.recordEvent(8653358);
Logging.recordEvent(var14, 8653359);
Logging.recordEvent(var13, 8653360);
var20 = 8653358;
Flux var23 = Flux.range(var14, var13);
var1 = 0;
var23 = Logging.recordEvent(var23, 8653361);
Logging.recordEvent(8653362);
BiFunction var10002 = (one, two) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$combineStreams$4", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$combineStreams$4") + 1L);
return Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$combineStreams$4"), 1L) ? Unlogged$Probed$$lambda$combineStreams$4(one, two) : String.format("First Flux: %d, Second Flux: %d", one, two);
};
Logging.recordEvent(var10002, 8653363);
BiFunction var15 = var10002;
Flux var16 = var23;
Logging.recordEvent(var22, 8653364);
Logging.recordEvent(var16, 8653365);
Logging.recordEvent(var15, 8653366);
var20 = 8653364;
var22 = var22.zipWith(var16, var15);
var1 = 0;
var22 = Logging.recordEvent(var22, 8653367);
Logging.recordEvent(elements, 8653368);
Logging.recordEvent(8653369);
Logging.recordEvent(elements, 8653370);
Consumer var24 = (elem) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$combineStreams$5", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$combineStreams$5") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$combineStreams$5"), 1L)) {
Unlogged$Probed$$lambda$combineStreams$5(elements, elem);
} else {
elements.add(elem);
}
};
Logging.recordEvent(var24, 8653371);
Logging.recordEvent(8653372);
Consumer var18 = var24;
Logging.recordEvent(var22, 8653373);
Logging.recordEvent(var18, 8653374);
var20 = 8653373;
Disposable var25 = var22.subscribe(var18);
var1 = 0;
Logging.recordEvent(var25, 8653375);
Logging.recordEvent(8653376);
Logging.recordEvent(elements, 8653377);
Logging.recordEvent(elements, 8653378);
return elements;
} catch (Throwable var19) {
Logging.recordEvent(var1, 8653379);
Logging.recordEvent(var19, 8653380);
Logging.recordEvent(var19, 8653381);
throw var19;
}
}
@RequestMapping({"/combine/1"})
public List<String> combineStreams() {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("combineStreams", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("combineStreams") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("combineStreams"), 1L)) {
return this.Unlogged$Probed$$combineStreams();
} else {
List<String> elements = new ArrayList();
Flux.just(new Integer[]{1, 2, 3, 4}).log().map((i) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$combineStreams$3", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$combineStreams$3") + 1L);
return Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$combineStreams$3"), 1L) ? Unlogged$Probed$$lambda$combineStreams$3(i) : i * 2;
}).zipWith(Flux.range(0, Integer.MAX_VALUE), (one, two) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$combineStreams$4", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$combineStreams$4") + 1L);
return Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$combineStreams$4"), 1L) ? Unlogged$Probed$$lambda$combineStreams$4(one, two) : String.format("First Flux: %d, Second Flux: %d", one, two);
}).subscribe((elem) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$combineStreams$5", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$combineStreams$5") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$combineStreams$5"), 1L)) {
Unlogged$Probed$$lambda$combineStreams$5(elements, elem);
} else {
elements.add(elem);
}
});
return elements;
}
}
public List<Integer> Unlogged$Probed$$parallelFluxExample() throws InterruptedException {
byte var1 = 0;
try {
Logging.recordEvent(this, 8653384);
Logging.recordEvent(8653385);
Logging.recordEvent(8653386);
Logging.recordEvent(8653387);
int var29 = 8653387;
ArrayList var10000 = new ArrayList();
var1 = 0;
Logging.recordEvent(8653388);
Logging.recordEvent(var10000, 8653389);
Logging.recordEvent(var10000, 8653390);
List<Integer> elements = var10000;
Logging.recordEvent(8653391);
Logging.recordEvent(8, 8653392);
Integer[] var30 = new Integer[8];
Logging.recordEvent(var30, 8653393);
byte var3 = 1;
Logging.recordEvent(8653394);
Logging.recordEvent(var3, 8653395);
var29 = 8653394;
Integer var10003 = Integer.valueOf(var3);
var1 = 0;
Logging.recordEvent(var10003, 8653396);
Integer var4 = var10003;
Logging.recordArrayStore(var30, 0, var4, 8653397);
var29 = 8653397;
var30[0] = var4;
var1 = 0;
byte var5 = 2;
Logging.recordEvent(8653400);
Logging.recordEvent(var5, 8653401);
var29 = 8653400;
var10003 = Integer.valueOf(var5);
var1 = 0;
Logging.recordEvent(var10003, 8653402);
Integer var6 = var10003;
Logging.recordArrayStore(var30, 1, var6, 8653403);
var29 = 8653403;
var30[1] = var6;
var1 = 0;
byte var7 = 3;
Logging.recordEvent(8653406);
Logging.recordEvent(var7, 8653407);
var29 = 8653406;
var10003 = Integer.valueOf(var7);
var1 = 0;
Logging.recordEvent(var10003, 8653408);
Integer var8 = var10003;
Logging.recordArrayStore(var30, 2, var8, 8653409);
var29 = 8653409;
var30[2] = var8;
var1 = 0;
byte var9 = 4;
Logging.recordEvent(8653412);
Logging.recordEvent(var9, 8653413);
var29 = 8653412;
var10003 = Integer.valueOf(var9);
var1 = 0;
Logging.recordEvent(var10003, 8653414);
Integer var10 = var10003;
Logging.recordArrayStore(var30, 3, var10, 8653415);
var29 = 8653415;
var30[3] = var10;
var1 = 0;
byte var11 = 5;
Logging.recordEvent(8653418);
Logging.recordEvent(var11, 8653419);
var29 = 8653418;
var10003 = Integer.valueOf(var11);
var1 = 0;
Logging.recordEvent(var10003, 8653420);
Integer var12 = var10003;
Logging.recordArrayStore(var30, 4, var12, 8653421);
var29 = 8653421;
var30[4] = var12;
var1 = 0;
byte var13 = 6;
Logging.recordEvent(8653424);
Logging.recordEvent(var13, 8653425);
var29 = 8653424;
var10003 = Integer.valueOf(var13);
var1 = 0;
Logging.recordEvent(var10003, 8653426);
Integer var14 = var10003;
Logging.recordArrayStore(var30, 5, var14, 8653427);
var29 = 8653427;
var30[5] = var14;
var1 = 0;
byte var15 = 7;
Logging.recordEvent(8653430);
Logging.recordEvent(var15, 8653431);
var29 = 8653430;
var10003 = Integer.valueOf(var15);
var1 = 0;
Logging.recordEvent(var10003, 8653432);
Integer var16 = var10003;
Logging.recordArrayStore(var30, 6, var16, 8653433);
var29 = 8653433;
var30[6] = var16;
var1 = 0;
byte var17 = 8;
Logging.recordEvent(8653436);
Logging.recordEvent(var17, 8653437);
var29 = 8653436;
var10003 = Integer.valueOf(var17);
var1 = 0;
Logging.recordEvent(var10003, 8653438);
Integer var18 = var10003;
Logging.recordArrayStore(var30, 7, var18, 8653439);
var29 = 8653439;
var30[7] = var18;
var1 = 0;
Integer[] var19 = var30;
Logging.recordEvent(8653442);
Logging.recordEvent(var19, 8653443);
var29 = 8653442;
Flux var31 = Flux.just(var19);
var1 = 0;
var31 = Logging.recordEvent(var31, 8653444);
Logging.recordEvent(8653445);
Logging.recordEvent(var31, 8653446);
var29 = 8653446;
ParallelFlux var32 = var31.parallel();
var1 = 0;
Logging.recordEvent(var32, 8653447);
Logging.recordEvent(8653448);
Logging.recordEvent(8653449);
var29 = 8653449;
Scheduler var10001 = Schedulers.parallel();
var1 = 0;
Logging.recordEvent(var10001, 8653450);
Scheduler var20 = var10001;
Logging.recordEvent(var32, 8653451);
Logging.recordEvent(var20, 8653452);
var29 = 8653451;
var32 = var32.runOn(var20);
var1 = 0;
Logging.recordEvent(var32, 8653453);
Logging.recordEvent(8653454);
Function var33 = (i) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$parallelFluxExample$6", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$parallelFluxExample$6") + 1L);
return Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$parallelFluxExample$6"), 1L) ? Unlogged$Probed$$lambda$parallelFluxExample$6(i) : i * 2;
};
Logging.recordEvent(var33, 8653455);
Logging.recordEvent(8653456);
Function var21 = var33;
Logging.recordEvent(var32, 8653457);
Logging.recordEvent(var21, 8653458);
var29 = 8653457;
var32 = var32.map(var21);
var1 = 0;
Logging.recordEvent(var32, 8653459);
Logging.recordEvent(var32, 8653460);
ParallelFlux<Integer> parallelFlux = var32;
Logging.recordEvent(8653461);
Logging.recordEvent(parallelFlux, 8653462);
Logging.recordEvent(elements, 8653463);
Logging.recordEvent(8653464);
Logging.recordEvent(elements, 8653465);
var29 = 8653464;
Object var10002 = Objects.requireNonNull(elements);
var1 = 0;
Logging.recordEvent(var10002, 8653466);
Logging.recordEvent(8653467);
Logging.recordEvent(elements, 8653468);
Consumer var34 = elements::add;
Logging.recordEvent(var34, 8653469);
Consumer var25 = var34;
Logging.recordEvent(parallelFlux, 8653470);
Logging.recordEvent(var25, 8653471);
var29 = 8653470;
Disposable var35 = parallelFlux.subscribe(var25);
var1 = 0;
Logging.recordEvent(var35, 8653472);
Logging.recordEvent(8653473);
long var26 = 500L;
Logging.recordEvent(8653474);
Logging.recordEvent(var26, 8653475);
var29 = 8653474;
Thread.sleep(var26);
var1 = 0;
Logging.recordEvent(8653476);
Logging.recordEvent(8653477);
Logging.recordEvent(elements, 8653478);
Logging.recordEvent(elements, 8653479);
return elements;
} catch (Throwable var28) {
Logging.recordEvent(var1, 8653480);
Logging.recordEvent(var28, 8653481);
Logging.recordEvent(var28, 8653482);
throw var28;
}
}
@RequestMapping({"/parallel"})
public List<Integer> parallelFluxExample() throws InterruptedException {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("parallelFluxExample", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("parallelFluxExample") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("parallelFluxExample"), 1L)) {
return this.Unlogged$Probed$$parallelFluxExample();
} else {
List<Integer> elements = new ArrayList();
ParallelFlux<Integer> parallelFlux = Flux.just(new Integer[]{1, 2, 3, 4, 5, 6, 7, 8}).parallel().runOn(Schedulers.parallel()).map((i) -> {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$parallelFluxExample$6", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$parallelFluxExample$6") + 1L);
return Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("lambda$parallelFluxExample$6"), 1L) ? Unlogged$Probed$$lambda$parallelFluxExample$6(i) : i * 2;
});
Objects.requireNonNull(elements);
parallelFlux.subscribe(elements::add);
Thread.sleep(500L);
return elements;
}
}
public List<Integer> Unlogged$Probed$$disposableExample() throws InterruptedException {
byte var1 = 0;
try {
Logging.recordEvent(this, 8653485);
Logging.recordEvent(8653486);
Logging.recordEvent(8653487);
Logging.recordEvent(8653488);
int var26 = 8653488;
ArrayList var10000 = new ArrayList();
var1 = 0;
Logging.recordEvent(8653489);
Logging.recordEvent(var10000, 8653490);
Logging.recordEvent(var10000, 8653491);
List<Integer> elements = var10000;
Logging.recordEvent(8653492);
Logging.recordEvent(5, 8653493);
Integer[] var27 = new Integer[5];
Logging.recordEvent(var27, 8653494);
byte var3 = 1;
Logging.recordEvent(8653495);
Logging.recordEvent(var3, 8653496);
var26 = 8653495;
Integer var10003 = Integer.valueOf(var3);
var1 = 0;
Logging.recordEvent(var10003, 8653497);
Integer var4 = var10003;
Logging.recordArrayStore(var27, 0, var4, 8653498);
var26 = 8653498;
var27[0] = var4;
var1 = 0;
byte var5 = 2;
Logging.recordEvent(8653501);
Logging.recordEvent(var5, 8653502);
var26 = 8653501;
var10003 = Integer.valueOf(var5);
var1 = 0;
Logging.recordEvent(var10003, 8653503);
Integer var6 = var10003;
Logging.recordArrayStore(var27, 1, var6, 8653504);
var26 = 8653504;
var27[1] = var6;
var1 = 0;
byte var7 = 3;
Logging.recordEvent(8653507);
Logging.recordEvent(var7, 8653508);
var26 = 8653507;
var10003 = Integer.valueOf(var7);
var1 = 0;
Logging.recordEvent(var10003, 8653509);
Integer var8 = var10003;
Logging.recordArrayStore(var27, 2, var8, 8653510);
var26 = 8653510;
var27[2] = var8;
var1 = 0;
byte var9 = 4;
Logging.recordEvent(8653513);
Logging.recordEvent(var9, 8653514);
var26 = 8653513;
var10003 = Integer.valueOf(var9);
var1 = 0;
Logging.recordEvent(var10003, 8653515);
Integer var10 = var10003;
Logging.recordArrayStore(var27, 3, var10, 8653516);
var26 = 8653516;
var27[3] = var10;
var1 = 0;
byte var11 = 5;
Logging.recordEvent(8653519);
Logging.recordEvent(var11, 8653520);
var26 = 8653519;
var10003 = Integer.valueOf(var11);
var1 = 0;
Logging.recordEvent(var10003, 8653521);
Integer var12 = var10003;
Logging.recordArrayStore(var27, 4, var12, 8653522);
var26 = 8653522;
var27[4] = var12;
var1 = 0;
Integer[] var13 = var27;
Logging.recordEvent(8653525);
Logging.recordEvent(var13, 8653526);
var26 = 8653525;
Flux var28 = Flux.just(var13);
var1 = 0;
var28 = Logging.recordEvent(var28, 8653527);
Logging.recordEvent(8653528);
long var14 = 1L;
Logging.recordEvent(8653529);
Logging.recordEvent(var14, 8653530);
var26 = 8653529;
Duration var10001 = Duration.ofSeconds(var14);
var1 = 0;
Logging.recordEvent(var10001, 8653531);
Duration var16 = var10001;
Logging.recordEvent(var28, 8653532);
Logging.recordEvent(var16, 8653533);
var26 = 8653532;
var28 = var28.delayElements(var16);
var1 = 0;
var28 = Logging.recordEvent(var28, 8653534);
Logging.recordEvent(elements, 8653535);
Logging.recordEvent(8653536);
Logging.recordEvent(8653537);
Logging.recordEvent(elements, 8653538);
var26 = 8653537;
Object var10002 = Objects.requireNonNull(elements);
var1 = 0;
Logging.recordEvent(var10002, 8653539);
Logging.recordEvent(8653540);
Logging.recordEvent(elements, 8653541);
Consumer var29 = elements::add;
Logging.recordEvent(var29, 8653542);
Consumer var19 = var29;
Logging.recordEvent(var28, 8653543);
Logging.recordEvent(var19, 8653544);
var26 = 8653543;
Disposable var30 = var28.subscribe(var19);
var1 = 0;
Logging.recordEvent(var30, 8653545);
Logging.recordEvent(var30, 8653546);
Disposable disposable = var30;
Logging.recordEvent(8653547);
long var21 = 3500L;
Logging.recordEvent(8653548);
Logging.recordEvent(var21, 8653549);
var26 = 8653548;
Thread.sleep(var21);
var1 = 0;
Logging.recordEvent(8653550);
Logging.recordEvent(8653551);
Logging.recordEvent(disposable, 8653552);
Logging.recordEvent(disposable, 8653553);
var26 = 8653553;
disposable.dispose();
var1 = 0;
Logging.recordEvent(8653554);
Logging.recordEvent(8653555);
long var23 = 2000L;
Logging.recordEvent(8653556);
Logging.recordEvent(var23, 8653557);
var26 = 8653556;
Thread.sleep(var23);
var1 = 0;
Logging.recordEvent(8653558);
Logging.recordEvent(8653559);
Logging.recordEvent(elements, 8653560);
Logging.recordEvent(elements, 8653561);
return elements;
} catch (Throwable var25) {
Logging.recordEvent(var1, 8653562);
Logging.recordEvent(var25, 8653563);
Logging.recordEvent(var25, 8653564);
throw var25;
}
}
@RequestMapping({"/disposable"})
public List<Integer> disposableExample() throws InterruptedException {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("disposableExample", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("disposableExample") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("disposableExample"), 1L)) {
return this.Unlogged$Probed$$disposableExample();
} else {
List<Integer> elements = new ArrayList();
Flux var10000 = Flux.just(new Integer[]{1, 2, 3, 4, 5}).delayElements(Duration.ofSeconds(1L));
Objects.requireNonNull(elements);
Disposable disposable = var10000.subscribe(elements::add);
Thread.sleep(3500L);
disposable.dispose();
Thread.sleep(2000L);
return elements;
}
}
public Flux<Tuple4<Integer, String, Double, Boolean>> Unlogged$Probed$$tuple4Example() {
byte var1 = 0;
try {
Logging.recordEvent(this, 8653567);
Logging.recordEvent(8653568);
Logging.recordEvent(4, 8653569);
Integer[] var10000 = new Integer[4];
Logging.recordEvent(var10000, 8653570);
byte var2 = 1;
Logging.recordEvent(8653571);
Logging.recordEvent(var2, 8653572);
int var48 = 8653571;
Integer var10003 = Integer.valueOf(var2);
var1 = 0;
Logging.recordEvent(var10003, 8653573);
Integer var3 = var10003;
Logging.recordArrayStore(var10000, 0, var3, 8653574);
var48 = 8653574;
var10000[0] = var3;
var1 = 0;
byte var4 = 2;
Logging.recordEvent(8653577);
Logging.recordEvent(var4, 8653578);
var48 = 8653577;
var10003 = Integer.valueOf(var4);
var1 = 0;
Logging.recordEvent(var10003, 8653579);
Integer var5 = var10003;
Logging.recordArrayStore(var10000, 1, var5, 8653580);
var48 = 8653580;
var10000[1] = var5;
var1 = 0;
byte var6 = 3;
Logging.recordEvent(8653583);
Logging.recordEvent(var6, 8653584);
var48 = 8653583;
var10003 = Integer.valueOf(var6);
var1 = 0;
Logging.recordEvent(var10003, 8653585);
Integer var7 = var10003;
Logging.recordArrayStore(var10000, 2, var7, 8653586);
var48 = 8653586;
var10000[2] = var7;
var1 = 0;
byte var8 = 4;
Logging.recordEvent(8653589);
Logging.recordEvent(var8, 8653590);
var48 = 8653589;
var10003 = Integer.valueOf(var8);
var1 = 0;
Logging.recordEvent(var10003, 8653591);
Integer var9 = var10003;
Logging.recordArrayStore(var10000, 3, var9, 8653592);
var48 = 8653592;
var10000[3] = var9;
var1 = 0;
Integer[] var10 = var10000;
Logging.recordEvent(8653595);
Logging.recordEvent(var10, 8653596);
var48 = 8653595;
Flux var49 = Flux.just(var10);
var1 = 0;
var49 = Logging.recordEvent(var49, 8653597);
Logging.recordEvent(var49, 8653598);
Flux<Integer> flux1 = var49;
Logging.recordEvent(8653599);
Logging.recordEvent(4, 8653600);
String[] var50 = new String[4];
Logging.recordEvent(var50, 8653601);
String var12 = "A";
Logging.recordArrayStore(var50, 0, var12, 8653602);
var48 = 8653602;
var50[0] = var12;
var1 = 0;
String var13 = "B";
Logging.recordArrayStore(var50, 1, var13, 8653605);
var48 = 8653605;
var50[1] = var13;
var1 = 0;
String var14 = "C";
Logging.recordArrayStore(var50, 2, var14, 8653608);
var48 = 8653608;
var50[2] = var14;
var1 = 0;
String var15 = "D";
Logging.recordArrayStore(var50, 3, var15, 8653611);
var48 = 8653611;
var50[3] = var15;
var1 = 0;
String[] var16 = var50;
Logging.recordEvent(8653614);
Logging.recordEvent(var16, 8653615);
var48 = 8653614;
var49 = Flux.just(var16);
var1 = 0;
var49 = Logging.recordEvent(var49, 8653616);
Logging.recordEvent(var49, 8653617);
Flux<String> flux2 = var49;
Logging.recordEvent(8653618);
Logging.recordEvent(4, 8653619);
Double[] var51 = new Double[4];
Logging.recordEvent(var51, 8653620);
double var18 = 1.1D;
Logging.recordEvent(8653621);
Logging.recordEvent(var18, 8653622);
var48 = 8653621;
Double var53 = var18;
var1 = 0;
Logging.recordEvent(var53, 8653623);
Double var20 = var53;
Logging.recordArrayStore(var51, 0, var20, 8653624);
var48 = 8653624;
var51[0] = var20;
var1 = 0;
double var21 = 2.2D;
Logging.recordEvent(8653627);
Logging.recordEvent(var21, 8653628);
var48 = 8653627;
var53 = var21;
var1 = 0;
Logging.recordEvent(var53, 8653629);
Double var23 = var53;
Logging.recordArrayStore(var51, 1, var23, 8653630);
var48 = 8653630;
var51[1] = var23;
var1 = 0;
double var24 = 3.3D;
Logging.recordEvent(8653633);
Logging.recordEvent(var24, 8653634);
var48 = 8653633;
var53 = var24;
var1 = 0;
Logging.recordEvent(var53, 8653635);
Double var26 = var53;
Logging.recordArrayStore(var51, 2, var26, 8653636);
var48 = 8653636;
var51[2] = var26;
var1 = 0;
double var27 = 4.4D;
Logging.recordEvent(8653639);
Logging.recordEvent(var27, 8653640);
var48 = 8653639;
var53 = var27;
var1 = 0;
Logging.recordEvent(var53, 8653641);
Double var29 = var53;
Logging.recordArrayStore(var51, 3, var29, 8653642);
var48 = 8653642;
var51[3] = var29;
var1 = 0;
Double[] var30 = var51;
Logging.recordEvent(8653645);
Logging.recordEvent(var30, 8653646);
var48 = 8653645;
var49 = Flux.just(var30);
var1 = 0;
var49 = Logging.recordEvent(var49, 8653647);
Logging.recordEvent(var49, 8653648);
Flux<Double> flux3 = var49;
Logging.recordEvent(8653649);
Logging.recordEvent(4, 8653650);
Boolean[] var52 = new Boolean[4];
Logging.recordEvent(var52, 8653651);
boolean var32 = true;
Logging.recordEvent(8653652);
Logging.recordEvent(var32, 8653653);
var48 = 8653652;
Boolean var54 = var32;
var1 = 0;
Logging.recordEvent(var54, 8653654);
Boolean var33 = var54;
Logging.recordArrayStore(var52, 0, var33, 8653655);
var48 = 8653655;
var52[0] = var33;
var1 = 0;
boolean var34 = false;
Logging.recordEvent(8653658);
Logging.recordEvent(var34, 8653659);
var48 = 8653658;
var54 = var34;
var1 = 0;
Logging.recordEvent(var54, 8653660);
Boolean var35 = var54;
Logging.recordArrayStore(var52, 1, var35, 8653661);
var48 = 8653661;
var52[1] = var35;
var1 = 0;
boolean var36 = true;
Logging.recordEvent(8653664);
Logging.recordEvent(var36, 8653665);
var48 = 8653664;
var54 = var36;
var1 = 0;
Logging.recordEvent(var54, 8653666);
Boolean var37 = var54;
Logging.recordArrayStore(var52, 2, var37, 8653667);
var48 = 8653667;
var52[2] = var37;
var1 = 0;
boolean var38 = false;
Logging.recordEvent(8653670);
Logging.recordEvent(var38, 8653671);
var48 = 8653670;
var54 = var38;
var1 = 0;
Logging.recordEvent(var54, 8653672);
Boolean var39 = var54;
Logging.recordArrayStore(var52, 3, var39, 8653673);
var48 = 8653673;
var52[3] = var39;
var1 = 0;
Boolean[] var40 = var52;
Logging.recordEvent(8653676);
Logging.recordEvent(var40, 8653677);
var48 = 8653676;
var49 = Flux.just(var40);
var1 = 0;
var49 = Logging.recordEvent(var49, 8653678);
Logging.recordEvent(var49, 8653679);
Flux<Boolean> flux4 = var49;
Logging.recordEvent(8653680);
Logging.recordEvent(flux1, 8653681);
Logging.recordEvent(flux2, 8653682);
Logging.recordEvent(flux3, 8653683);
Logging.recordEvent(flux4, 8653684);
Logging.recordEvent(8653685);
Logging.recordEvent(flux1, 8653686);
Logging.recordEvent(flux2, 8653687);
Logging.recordEvent(flux3, 8653688);
Logging.recordEvent(flux4, 8653689);
var48 = 8653685;
var49 = Flux.zip(flux1, flux2, flux3, flux4);
var1 = 0;
var49 = Logging.recordEvent(var49, 8653690);
Logging.recordEvent(var49, 8653691);
Flux<Tuple4<Integer, String, Double, Boolean>> combinedFlux = var49;
Logging.recordEvent(8653692);
Logging.recordEvent(combinedFlux, 8653693);
return Logging.recordEvent(combinedFlux, 8653694);
} catch (Throwable var47) {
Logging.recordEvent(var1, 8653695);
Logging.recordEvent(var47, 8653696);
Logging.recordEvent(var47, 8653697);
throw var47;
}
}
@RequestMapping({"/tuple4"})
public Flux<Tuple4<Integer, String, Double, Boolean>> tuple4Example() {
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("tuple4Example", (Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("tuple4Example") + 1L);
if (Runtime.probeCounter((Long)org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.get("tuple4Example"), 1L)) {
return this.Unlogged$Probed$$tuple4Example();
} else {
Flux<Integer> flux1 = Flux.just(new Integer[]{1, 2, 3, 4});
Flux<String> flux2 = Flux.just(new String[]{"A", "B", "C", "D"});
Flux<Double> flux3 = Flux.just(new Double[]{1.1D, 2.2D, 3.3D, 4.4D});
Flux<Boolean> flux4 = Flux.just(new Boolean[]{true, false, true, false});
Flux<Tuple4<Integer, String, Double, Boolean>> combinedFlux = Flux.zip(flux1, flux2, flux3, flux4);
return combinedFlux;
}
}
// $FF: synthetic method
private static Integer Unlogged$Probed$$lambda$parallelFluxExample$6(Integer i) {
byte var1 = 0;
try {
Logging.recordEvent(8653700);
Logging.recordEvent(i, 8653701);
Logging.recordEvent(8653702);
Logging.recordEvent(i, 8653703);
Logging.recordEvent(i, 8653704);
int var4 = 8653704;
int var10000 = i;
var1 = 0;
Logging.recordEvent(var10000, 8653705);
int var2 = var10000 * 2;
Logging.recordEvent(8653706);
Logging.recordEvent(var2, 8653707);
var4 = 8653706;
Integer var5 = var2;
var1 = 0;
Logging.recordEvent(var5, 8653708);
Logging.recordEvent(var5, 8653709);
return var5;
} catch (Throwable var3) {
Logging.recordEvent(var1, 8653710);
Logging.recordEvent(var3, 8653711);
Logging.recordEvent(var3, 8653712);
throw var3;
}
}
// $FF: synthetic method
private static void Unlogged$Probed$$lambda$combineStreams$5(List elements, String elem) {
byte var2 = 0;
try {
Logging.recordEvent(8653715);
Logging.recordEvent(elements, 8653716);
Logging.recordEvent(elem, 8653717);
Logging.recordEvent(8653718);
Logging.recordEvent(elements, 8653719);
Logging.recordEvent(elem, 8653720);
Logging.recordEvent(elements, 8653721);
Logging.recordEvent(elem, 8653722);
int var5 = 8653721;
boolean var10000 = elements.add(elem);
var2 = 0;
Logging.recordEvent(var10000, 8653723);
Logging.recordEvent(8653724);
} catch (Throwable var4) {
Logging.recordEvent(var2, 8653725);
Logging.recordEvent(var4, 8653726);
Logging.recordEvent(var4, 8653727);
throw var4;
}
}
// $FF: synthetic method
private static String Unlogged$Probed$$lambda$combineStreams$4(Integer one, Integer two) {
byte var2 = 0;
try {
Logging.recordEvent(8653730);
Logging.recordEvent(one, 8653731);
Logging.recordEvent(two, 8653732);
Logging.recordEvent(8653733);
Logging.recordEvent(2, 8653734);
Object[] var10001 = new Object[2];
Logging.recordEvent(var10001, 8653735);
Logging.recordEvent(one, 8653736);
Logging.recordArrayStore(var10001, 0, one, 8653737);
int var8 = 8653737;
var10001[0] = one;
var2 = 0;
Logging.recordEvent(two, 8653740);
Logging.recordArrayStore(var10001, 1, two, 8653741);
var8 = 8653741;
var10001[1] = two;
var2 = 0;
Object[] var5 = var10001;
String var6 = "First Flux: %d, Second Flux: %d";
Logging.recordEvent(8653744);
Logging.recordEvent(var6, 8653745);
Logging.recordEvent(var5, 8653746);
var8 = 8653744;
String var10000 = String.format(var6, var5);
var2 = 0;
Logging.recordEvent(var10000, 8653747);
Logging.recordEvent(var10000, 8653748);
return var10000;
} catch (Throwable var7) {
Logging.recordEvent(var2, 8653749);
Logging.recordEvent(var7, 8653750);
Logging.recordEvent(var7, 8653751);
throw var7;
}
}
// $FF: synthetic method
private static Integer Unlogged$Probed$$lambda$combineStreams$3(Integer i) {
byte var1 = 0;
try {
Logging.recordEvent(8653754);
Logging.recordEvent(i, 8653755);
Logging.recordEvent(8653756);
Logging.recordEvent(i, 8653757);
Logging.recordEvent(i, 8653758);
int var4 = 8653758;
int var10000 = i;
var1 = 0;
Logging.recordEvent(var10000, 8653759);
int var2 = var10000 * 2;
Logging.recordEvent(8653760);
Logging.recordEvent(var2, 8653761);
var4 = 8653760;
Integer var5 = var2;
var1 = 0;
Logging.recordEvent(var5, 8653762);
Logging.recordEvent(var5, 8653763);
return var5;
} catch (Throwable var3) {
Logging.recordEvent(var1, 8653764);
Logging.recordEvent(var3, 8653765);
Logging.recordEvent(var3, 8653766);
throw var3;
}
}
// $FF: synthetic method
private static Integer Unlogged$Probed$$lambda$concurrent$2(Integer i) {
byte var1 = 0;
try {
Logging.recordEvent(8653769);
Logging.recordEvent(i, 8653770);
Logging.recordEvent(8653771);
Logging.recordEvent(i, 8653772);
Logging.recordEvent(i, 8653773);
int var4 = 8653773;
int var10000 = i;
var1 = 0;
Logging.recordEvent(var10000, 8653774);
int var2 = var10000 * 2;
Logging.recordEvent(8653775);
Logging.recordEvent(var2, 8653776);
var4 = 8653775;
Integer var5 = var2;
var1 = 0;
Logging.recordEvent(var5, 8653777);
Logging.recordEvent(var5, 8653778);
return var5;
} catch (Throwable var3) {
Logging.recordEvent(var1, 8653779);
Logging.recordEvent(var3, 8653780);
Logging.recordEvent(var3, 8653781);
throw var3;
}
}
// $FF: synthetic method
private static void Unlogged$Probed$$lambda$fluxThrottling$1(AtomicInteger triesLift, FluxSink fluxSink) {
byte var2 = 0;
try {
Logging.recordEvent(8653784);
Logging.recordEvent(triesLift, 8653785);
Logging.recordEvent(fluxSink, 8653786);
while(true) {
Logging.recordEvent(8653787);
Logging.recordEvent(triesLift, 8653788);
Logging.recordEvent(triesLift, 8653789);
int var8 = 8653789;
int var10000 = triesLift.get();
var2 = 0;
Logging.recordEvent(var10000, 8653790);
var8 = 8653791;
if (var10000 <= 0) {
Logging.recordEvent(8653813);
Logging.recordEvent(8653814);
return;
}
Logging.recordEvent(8653792);
Logging.recordEvent(triesLift, 8653793);
Logging.recordEvent(triesLift, 8653794);
var8 = 8653794;
var10000 = triesLift.getAndDecrement();
var2 = 0;
Logging.recordEvent(var10000, 8653795);
Logging.recordEvent(8653796);
Logging.recordEvent(fluxSink, 8653797);
Logging.recordEvent(triesLift, 8653798);
Logging.recordEvent(triesLift, 8653799);
var8 = 8653799;
int var10001 = triesLift.get();
var2 = 0;
Logging.recordEvent(var10001, 8653800);
Logging.recordEvent(8653801);
Logging.recordEvent(8653802);
var8 = 8653802;
long var10002 = System.currentTimeMillis();
var2 = 0;
Logging.recordEvent(var10002, 8653803);
Logging.recordEvent(8653804);
long var3 = var10002;
int var5 = var10001;
Logging.recordEvent(var5, 8653805);
Logging.recordEvent(var3, 8653806);
String var10 = "Print : Counter : " + var5 + " - " + var3;
Logging.recordEvent(var10, 8653807);
Logging.recordEvent(8653808);
String var6 = var10;
Logging.recordEvent(fluxSink, 8653809);
Logging.recordEvent(var6, 8653810);
var8 = 8653809;
FluxSink var9 = fluxSink.next(var6);
var2 = 0;
Logging.recordEvent(var9, 8653811);
var8 = 8653812;
}
} catch (Throwable var7) {
Logging.recordEvent(var2, 8653815);
Logging.recordEvent(var7, 8653816);
Logging.recordEvent(var7, 8653817);
throw var7;
}
}
// $FF: synthetic method
private static void Unlogged$Probed$$lambda$connectableFluxExample$0(AtomicInteger triesLift, FluxSink fluxSink) {
byte var2 = 0;
try {
Logging.recordEvent(8653820);
Logging.recordEvent(triesLift, 8653821);
Logging.recordEvent(fluxSink, 8653822);
while(true) {
Logging.recordEvent(8653823);
Logging.recordEvent(triesLift, 8653824);
Logging.recordEvent(triesLift, 8653825);
int var7 = 8653825;
int var10000 = triesLift.get();
var2 = 0;
Logging.recordEvent(var10000, 8653826);
var7 = 8653827;
if (var10000 <= 0) {
Logging.recordEvent(8653843);
Logging.recordEvent(8653844);
return;
}
Logging.recordEvent(8653828);
Logging.recordEvent(triesLift, 8653829);
Logging.recordEvent(triesLift, 8653830);
var7 = 8653830;
var10000 = triesLift.getAndDecrement();
var2 = 0;
Logging.recordEvent(var10000, 8653831);
Logging.recordEvent(8653832);
Logging.recordEvent(fluxSink, 8653833);
Logging.recordEvent(8653834);
var7 = 8653834;
long var10001 = System.currentTimeMillis();
var2 = 0;
Logging.recordEvent(var10001, 8653835);
long var3 = var10001;
Logging.recordEvent(8653836);
Logging.recordEvent(var3, 8653837);
var7 = 8653836;
Long var9 = var3;
var2 = 0;
Logging.recordEvent(var9, 8653838);
Long var5 = var9;
Logging.recordEvent(fluxSink, 8653839);
Logging.recordEvent(var5, 8653840);
var7 = 8653839;
FluxSink var8 = fluxSink.next(var5);
var2 = 0;
Logging.recordEvent(var8, 8653841);
var7 = 8653842;
}
} catch (Throwable var6) {
Logging.recordEvent(var2, 8653845);
Logging.recordEvent(var6, 8653846);
Logging.recordEvent(var6, 8653847);
throw var6;
}
}
static {
Runtime.registerClass("eNrtXQl4VOXVRkBIDAEEZWuwBVEJILn7AqKyahCBAsWqtfXOzJ0wMsnEyUTF7q3dtJvd3OtStXZfrLa1i23V7vu+t2r3XX+7b/89yUl4M/OdmXsngQlP8XnyqPPe894z7z3fds53v5kw4aH7J0yYsLpQ7FrZ35MvdHWFmZV9vcVcT9elYSqb778sE3YXVqYLPaViIZ8Piys3RZ9t6+1bP/xJZD6n4sOVFwWXBEzcMUTcUUHcsZ+4Q0U8ZWuh2B3ko/9aqqWDbKDZvpVOOb7hZj09Y+hamM14ac0OtdAJA83NmG507ZlbCkEmLJ5OPqRXjc6DoX9mEllHPujp6tiWuihMl+jDSc+fQPpNnfCGCVc0Xfdf/octjh781zB+PbAtj/4mR39TO9es7dvXk4bLboDLjlDQ3Eh6M2Yo8JsYn0T0jIfrg3x+177ecM2OMB3mLgmLWwulzp5cKRfkc5eHmRWdPX2lYn+6lCv0rOncunvbWRt3bt+4vnPtlhXbLu0Ji2vKv/yKrUF3uOaUXERx6ooNYV96zdL23eDEm8GJZnZiPjmxPSiGPaU1nmMbvu2uGPAJDW8GQ/qbWfbtbmF8Mv8R8ZQKllv5qinR31F8JbLcBniL4i5vAXxKGf7GCL+9yqMm/I7aj5ouu7PsUZff5q2kmvCoCb+L8YnR3zTG5w2IMfC8+ku5fMfaYjHYtyXXVwK7t7HdZAiRy2uFyNbwUnx4jhcvaEY6US1uyLO3g2di3Dj+yLghw3eAYatCyncyfmT0t5LxYwdYtux3kzxcDUbvii5awBqp9H834+Tpk8rCjPD3AN6mcOq9jLfCc8gNP4edpaCUS6tU3rV2V+f6ipbZ2VMKu8LioMSXBPn+cFuWNe5s31JxHX7R94EjTfxFFpXL7jqRL5nwsjXaoPydQPB+IGhmkuUKAlBc8uVupppOwawQ7QOAz1eIfg/gCxT29/Lnsxot+gfBEVF0z5BF/xAQiKJHBDFE/zBTzRZEvw9wlegfAVwl+kf587mNFv1j4IgsuieL/nEgkEX34oh+P1PNE0T/BOAq0T8JuEr0T/HnbY0W/QFwRBTdt2TRHwQCUfSIIIboDzHVQkH0TwOuEv0zgKtE/yx/vqjRon8OHBFENzVNk0X/PBAIog8QxBD9C0y1WBD9i4CrRP8S4CrRv8yfn9ho0b8CjsiiVxlIvwoEsuixBtKvMdVJguhfB1wl+jcAV4n+Tf58eaNF/xY4IoquVxlIvw0Eouh6rIH0O0y1QhD9u4CrRP8e4CrRv8+fa40W/QfgiCx6lYH0h0Agix5rIP0RU+mC6D8GXCX6TwBXif5T/twA0V+ZUPRiGKRLhWJHulAMO3r7U/lc3x5OOQzKf1F/tDwa1P78LeXr7dXtW6oQoBYPg69N/F3MclmNsrFWcUOgfAQom5nSVlAOPqmYfj7KpCasXdcNMIwiX7NEhzv8jO/gRH8nx13y/ZyNXHjUjyVaGkdSuDWXxqP6jopF9JZREK4ul2PEivwXIMhQPF1Q8fB9jiedg2A07sDNf6m4uSbefEQHrXy6vwI+Ib0wwFeRXvg1GKrSC7/hDIAvZAp+y/gqDiuyvwLCqqs/HxQVUbO7c8eupw1HTc0+pK8/1Zcu5lIhhsWAVRS1EXcYdPd17By6qDjySf8OfBwS+/RycUxb8aSr3AH4fw/8ovgRf4X4f4gu9KK/UwRx/8j4miQN/U9sdCqPB7GMHmOj0xV5RcIfB7xFESb/B3h5XvFNEf5Elbwi4X+unVeky/5SJa9I+F9ZLFVekfC/MY55xZVlecWoCaf7i/TgOoJSoTuX7lg78C8enoHt78x2JHSpVyfsUq0k2cYarim6z87hhkAO/wMcFqc2VlmX1wkE/wQCMdKtsm6GDP8Fhq2KB/dvxqdAFlMrD9oaX3818P2HG0CTEAj/ZbwZWtYo7kc0A3zUdpYO3m9ia+WD3XDu1rVnRzOngQcVpNNh79DMKMFt2+HabH/PAH9HNMz09XdH6Ip1hUIpum/QC9PhXM8lhb1hx5agO5UJzg5LQXagv923/+Lowz2FzJpuFYYeIt2gzZlBTyYf9i3ZUijs7e9dDZftLNHwuFoyJLnrAwdvWd22vRKlQN2ZK4Wg0dpiV59Gk5aVhYHZYTSWrwz6ugf6hJFX6YqrBv0YeZ0hsEGwHAHB0j4GwTcR+JZVNq7mSYy3QD917VjP8tPRFaWwMporIzTWjJ/8ngx+D43ba8p7G9sfOeOvemsgPxLIxbm/7cef+xMpdV8buItTdDvNUxmfDrOlV4z9bIk/G6pDSd5HsvREURqk8mH5F2kCR5ulKZNjVlenCn8z88+A/v7kesko7jey2irVWxifBZ193TebxmSzmYj+TitPP+zc11cKu1dsyoX5zMATKfSXMDxzhY7tUd9Y2jkwr0T6VqY/FtrqC+pJgwy0gMElb99gVBTDi/tzxXBroWdrfz6/oqJXH16QS0tm8m86+DfUJo2KwFC2SYFxBjAOhdoyBWNtppnMNHf/IHzEX5MPwmUP5/Bwe4gPt0dDWAwNtwtiNcZZYKkaWGczPg+689vHqjsv64OEdXCCgXZDrq+30Ed8+B2Pge8gDrJu+eI45iB7LJAPtW1dQa7ojNXe0t6VTbzcVnX1cxlvG4uufh6TLYT+5JEk/cnhruMQ7zrmQwSoOoAFjB93CHcAT4LvIHYAw7s1EnYAbUAudgDDOzlieEtP4gyu3ao6gOMYXzwWHcCTmex4eLwvOaCPNz34oXrmrlbkKeCkLLEbX2KS9kyu1KokXsz4SeJORbrqeL6qXZFRJHwJ4C2KpnUC4OUZxWsi/MQqGUXCT6qdUaTLllbJKBJOt98iZBQJX8Y4bkq96gBW0OosoJGry8FVceruezGn7sS4AhjFNbTvxV9DE+nJTDoZloaLEzGQ1dkcNqpn1sH4VOgjkt1BY4YmyLEnY9CZ4ShF8yDcALxFEZcm4OXN49oIt6o0D8Lt2s2DLnOq7Nkm3AV8osINqgk8VWg+hPuMTxz71TTRr2L6ydCB5xN34IqbcJ6FPsj3VDZNnk8NJ9/Jl9Xgi9T8dN1SjbPICYynAKOUjSfGEX0zGVKmfYfQQAg/lfGpYg9PV53GVzUrQpjw0wFvUcTGWsDLQ/i6CF9XJYQJX187hOmyDVV6eMJpfbJbCFHCNzE++poRsZ3BbKOoGemGc5BqRuTwmeCwVDPSBzYGKGpGRNAJBGKUGmVvTJDhZjBsVTy4sxgfi5oR8dGgc45QMyL8bMbHomZEfFuZ73DN6PBKtOpKlIJlGwRL+xgE33bgW6ZoXE9l/FCqGZHfO8BvaTWrm27ymhGR7wRyab5L5LFngkS6KyJ5JpdaVN3O0xifAU+iu56KQCnXHS35+osBXTX4AArZnWEUNJk+fgabuQWMuBSd3Q3ONHHfXDEaWPpIeTcDwTlAMCThCgUBPBfRmacz10yY3V19APYeBd29+ZFROtKl2MF5Ljg8FJxWxZdXTgFFEc4DTjEmLStZTJ4fkTyLK2aqmHwG47PHcx2THL0AHJXqmLrl1VXHJP5nMv8xo61jEhkRXcgvaKpUv5DxuaPNbRFZwGTzxn7lRfQppl8wDuuY5F8a/BNXY7YVMxlCjBlglOqYxFibKWSmtsN1zMNTwP1hkYWwiF/HJMsusFRN9vYwvvAQLWPQd8jBdxAnfo6WvIxB5BcBuZRjJ/JYOXYi3BsRUA/8FKGrzzO+aCy6+m4mWzxeyxjkZA84KUtsx5e4EBHQKHSCIHEv4yeO0XL+YuY7afS5xviJm65wWGTMuRTBl2ZO2lTkXIb21KBhHxsuhZMoplRcVeKrlikyf4T3A96i6G8uAbw883d9hF9aJfNH+GW1M3902b4qmT/CL4/+p0vI/BH+bMaTnEJBds9hu/pPoTB11x/rUyjIs+eCZ2IuztNG5uLI8Hlg2KqQ8vmMxz6FgoxeEF20RziFgvAXMq46hYLwFwHepnDqxYw39BQKcuQKcETMoXqu+pVCIngJEEivFOrDNd6qvryUqVSnUBD+MsDnK0R/OeALFPavYHxWo0W/EhwRRfdNWfSrgEAU3TfjiP5KppotiP4qwFWivxpwleivYXxuo0V/LTgii+7Lol8NBLLofhzRX8dU8wTRXw+4SvQ3AK4S/Y2MtzVa9DeBI5LohmbLol8DBJLoRBBD9GuZaqEg+nWAq0S/HnCV6Dcwftw4f2OZfL0RfJXeWDZ0Pe4by0R5E1BK2T6ijJ3tI1I60ywnLEYIv5nxRTCzvXzss335QletTF+557eAZ7IcdjI5bmXSxZB+ebhW+qW3N7+v2q7PTfwfhxMt4zvRQgFwGwTAMkUfRIfoUUZgidBebmf8BGgv14x9e+kOeqtkT4YDLnZjugPcljIohhEjgzJ8ayC/E8jFlmpoyVoqHSO4l5e5qgdxF+NLYbB4+WgGi770njDTT2/37xz6L05K9wbFiDfMq3swhR1+j7eBn0PirKoQR1nDqcH8dmZuPxCZPUU6b9vwZqiaXsaOy3fAdxiKy3UV6jhlcZlEpXfCHeTgdJIF57uYdFncl/fJiA5ezLOBKqLfw/jKcVhWIf/eC/5JZRXD1GOWVYjxfcAolVWIsTbT+5lJg3H98Tr32wweJ3K4onJoD/R3Q0S0x22iHwAj1ezgHsZ16HKvOwgnooyqgkKO3wuOi+O/6SavoBD5B4FcSu8bZsy3FIiQzgilmoEl9JQfZtyBnnJX3avzXXsilzKsfD4Me4c3zGCW9D64p7Q7xpB2xxDBR4BAys8aQ7tj8M50DGmBz2BRqfExxv0kg9HH2WhV3JNkyOh+NjpFURsg/BOAtyiazycBL68N3BDhn6pSGyD8gdq1AbrswSq1AcLpNM2SUBsg/NOMJ6kNkN1n2G4UtQFjYFvCmNYGyLPPgmdi7NllpxiR4efAsFUh5ecZj10bICM6WLNfqA0Q/kXGVbUBwr8EeJvCqS8z3tDaADnyFXBETN45whmPRPBVIBCTd07NMx6J6mtMpaoNEP51wOcrRP8G4AsU9t9kfFajRf8WOCKL7smifxsIZNG9OKJ/h6lmC6J/F3CV6N8DXCX69xmf22jRfwCOiKK7liz6D4FAFN214oj+I6aaJ4j+Y8BVov8EcJXoP2W8rdGiPwyOiKJ7miz6I0Agiu5pcUR/lKkWCqL/DHCV6D8HXCX6Lxgf77UB8vWX4KtYG/CcuLUBovwVUIpZDC9BFoNI6XzIS4TaAOG/YXx81QbIs9+CZ6IcvpZMjt8x6eIxPdzVgDv8nu9wQtyZOhn9gY1OrP9wV8M3DujhrsZBO9yVBPkjCCId7mr41tgf7ko3/5Pi5pp48+qHuxLfY8Anzsx9q3Jm/jgYqmbmdGrnpZwNUzXuJxhvH6eHu5KPfwYfpcNdTU2r63BX4v8L8Evim5pWKT6dRfo6XoSqxP0b4yuSNPS/s9HJcZfkZPQPNupQLMkJ/yfgLYow+Rfg5UvyGyP831WW5IT/p/aSnC77b5UleYST5xOuEZbkhB/BeJIlOdlNZLtRLMlN3RzrJTl5Ngk8E2Ov/AVvMpwMhq0KKY9kPPaSnIzo0V8rLMkJn8q4aklOeBPgbQqnmhlv6JKcHDkKHJHmzKahq+fMRNACBNKcmQhqzJmJahpTqZbkhLcCPl8h+nTAFyjsZzA+q9GizwRHZNFdWfSjgUAW3Y0j+iymmi2IPhtwlejHAK4S/VjG5zZa9DngiCi6acqizwUCUXTTjCP6PKaaJ4g+H3CV6AsAV4n+JMbbGi16Gzgii+7Loi8EAll0P47oxzHVQkH0JwOuEv0pgKtEX8T4eF+Sk6+LwVdpSW5adtwlOVEeD5TSGpQoY69BiZS2HV0nLMkJP4Hx8bUkJ89OBM9kOfxkcpzEpIe36/0PVvEpAJZCACxT9EG0crte2K5H+DLGD6HteuT2cnBbKtebtpV8ux6RrwBysaXaVrKWSovWG3gprXoQKxlfBoPFc8Z6sChGETyUaOjsjK12B/gmDtq2Jw/aWiICvZJABwL5kXjJHonBpMuh83x0tJ3nutzh7vPQ6T5NCAFV92kxvgK6x4+Offd4ea73nFxpT7UU4PYhs9U1oi52q7bhuw31oaeVtynHipE83O8b0DuJ6A25i4bvBvQu0Is9gpOwk/aY9OS4aUky8tlo5eGtlYd7lYGIWAUR0R43jFaDkaoroj1hN/HWS9UEYg3jh9TWS3L8VHBcnMu5ZvKtl0R+GpBLWy+JPNbWSyKkgz1vFrZeEr6WcTtJF7KOjZy4lQ0yWs9GnqKyQfgGwFsUAbUR8PLKxk0RvqlKZYPwM2pXNuiyM6tUNginIzJvFyobhG9mPEllg+zOYrvRVDY8Z6wrG+TZFvBMrGx4ZYeCkuHZYNiqkHIr47ErG2REhyveIVQ2CN/OuKqyQfhTAW9TOLWD8YZWNsiRneCIuAiRfq+eCHYBgZh6rP179UT1NKZSVTYI3w34fIXo5wC+QGH/dMZnNVr0c8ERSXRL+r16IjgPCCTRrdq/V09U5zPVbEH0ZwCuEv0CwFWiP5PxuY0W/VngiCy6I4t+IRDIojtxRA+Yap4gegpwlehpwFWiZxhva7ToITgiii79Xj0RZIFAFL3279UTVRdTLRRE3wO4SvQc4CrRL2J8UaNF3wuOyKJ7suh5IJBF9+KI3s1UiwXRewBXiV4AXCV6L+MnNlr0i8ERUXSjykBaBAJRdCPWQNrHVCcJopcAV4neD7hK9EsYX95o0S8FR0TRzSoD6WVAIIpuxhpI9zHVCkH0ywFXif5swFWiP4dxrdGiPxcckUWvMpA+Dwhk0WMNpM9nKl0Q/QWAq0R/IeAq0V/EuDHOq9Xk64vBV6labVlG3Go1UV4BlFI+kShj5xOJlI4uu1NIFhD+UsZtyNm87AAcJV31fIb9Ftv5uvKv8TJws1nI0FhWjc31EjmdqUZnWbiCRq9g3BvH51iQn1eCn9I5Fpa6vl+D+Spm9iFK3j1WUYKPhYuE/T1jcZKF9LxfCd9GOtHCsvU6T7SgO7wK7iCGq63XF66vZvJVh3dc/O8l9ykAXgMBsEwxjtIpgHfxO9yq/uxqxtdAa37rgWvNo915IbWD18HXaBIbmZt8BwaRvx7Im6uQ19WC38Dkp0KWdFldTHQIIh0ydLrwqN/E+FqoBdR3p2uYaV3cqgIZXctGG8bheTnk33Xgn3RejuXE/RkCYrweGKXzcizHisF0AzNtOlzUPdzvD0TEjRAR7XGb4E1gpBos3sz4GTAY3HrgBoOxLd7SF7gZvoA4DLh1/PIAkd8C5FLxlshjFW+JkE63pKPJNgsd9m2MbzlI5+bQPd8C95TOzbHKTwbYDAS3A4FUTrRcq7KcSMtdOnNtq6DGnYxvSzLovJWNtsctZZPRXWy0Q1HKJvxtgLcomtHbAS8vZb85wt9RpZRN+Dtrl7LpsndVKWUTTi7cLZSyCX8P40lK2WT3XrYbRSnbGjhhfUxL2eTZ+8AzMfY8b2TskeH7wbBVIeXdjMcuZZMRnU72AaGUTfg9jKtK2YTfC3ibwqkPMt7QUjY58iFwRMxL+sKh10TwYSAQ85J+zUOvieo+plKVsgn/CODzFaJ/FPAFCvuPMT6r0aJ/HByRRLc1XRb9fiCQRCeCGKJ/gqlmC6J/EnCV6J8CXCX6A4zPbbToD4IjsuiuLPpDQCCL7sYR/dNMNU8Q/TOAq0T/LOAq0T/HeFujRf88OCKKrpuy6F8AAlF03Ywj+heZaqEg+pcAV4n+ZcBVon+F8UWNFv2r4Igsui+L/jUgkEX344j+daZaLIj+DcBVon8TcJXo32L8+HFeayJfvw2+SrUm24j9ZiRRfgcopVoTUcauNREpHZV2DxfVVZOf7zF+UqN/Spec+T44Iy16bMNXL3qI4AdAIP2ULhHU+hVZ4vohcy2FRfi1Y1+Fy4T5YN/GfNgd+dc32l/UJb9/BH5Lv6hrm0bsX9Qlzh8DpxiappEsNH/CpO1xF5JkRKfI3cubBFTx/DDjJ4/D7Cb59wj4J2U3bfWPcQuMjwKjlN20TTcG08+YqeNwdvNwdnMgIn4OEdEet4n+AoyWKYb5XzKuHUqvpJDjvwLHpaymbdXxSgqR/xrIpawmkcfKahLhb5hQh1zJcbGt6ahASgeYQj/7O8btg5QTpXv+Hu4pTg8sT54e/AEIpLyUbSnyUnR23n3CbhTC/8S4B0NZfK0fY2vcyXFhjAbRuXXXxh2b1q7fqGoS+2/F84yB/w9V6brH4f6iLLZZKQsdlkeJmNWCLE8wvuYgBsmf4Z5ikNiOHCR/AQJZDadSDTrdjrJBpwlq/I3x05PMd/7ORmvjJs7J6B9stF6ROCf8n4C3KHrofwFenji/OcKrnW5HeIzT7eiyaqfbRTh5NuEBIXFO+BGMT1IkbgmfCHibgn8S41MbucgnRyaDI+Ii3xVyiERwJBCIi3y3Zg6RqKYwVZNikU/4VMDnK0RvAnyBwr6Z8WmNFv0ocEQW3ZVFbwECWXQ3jujTmKpVEL0VcJXo0wFXiT6D8aMbLfpMcEQU3TNl0Y8GAlF0z4wj+iymmiWIPhtwlejHAK4S/VjG5zRa9DngiCy6L4s+Fwhk0f04os9jqrmC6PMBV4m+AHCV6E9ifN44zyGSr23gq5hD9GPnEIlyIVCKiRo/QQ6RSI9j0vmwkliciIHOzHuQR2nVSP4UxhcKI/kiwFUj+WLGFwlRdTzgqqhaArgqqk5g/ASB/0TAVfwnAa7iX8p4u8DfDriKfxngKv7ljJ8s8K8AXMV/MuAq/pWMrzwEWl0H+Cq1Oke3krQ6DSilVufoVrJWpzNpR92tjlraQ5wBULU6k3FTaHUW4KpWZzPuwlPvqnuA21DoH16sjhzfNuD4NngZfk0H3GhiV8qHN6f8bOINQOACQTNP6JYpCMqHt0pXPGbyhHbmA65qZ6sAV7Wz1Yyf0ljFTwE3ZMVdWfE1QCAr7sZQ/FRmWiMofhrgKsVPB1yl+FrG1zZW8XXghqh4+anEqPh6IBAVV5xKXOnKBmZaJyi+EXCV4psAVyl+BuObGqv4meCGrLgvK94JBLLifgzFNzPTGYLiZwGuUnwL4CrFz2b8zENg9N4Kvoqjt5VozrwNKMXR20o4Z97OpJ11j950gg7tLTpLGL13MH62MHrvBFw1eu9i/KljsjxdVyjkw6BH1dDOw4bG1+EXfRo40sTpwIqWZpe9tnseEOwGgmZOeS5XEJS3NIUv5zDVDqGpPR1wVVM7F3BVUzuP8d2NFv18cEQW3ZNFfwYQyKJ7cUS/gKnOEUR/JuAq0Z8FuEr0Cxk/v9GiB+CIKHr5q00oegoIRNEVbzIpfEkz1TME0TOAq0QPAVeJnmX8wkaL3gWOiKK7miz6HiAQRXe1OKLnmCoQRL8IcJXoewFXiZ5nPHUIjOTd4Ks4krtOkpG8ByjFkdx1ko3kBSZN1z2S0xE9tMs3FEbyixnPQmEw2R2KzNBVN0MfM+ypm6HEDLm6GfqZ4SKI3ifGOnovz/XGPFD5QMKxW8kloIl0XrLjlc134x3HTPSXJqLXk9JflojeSEq/LxG9mZT+cqAXuxMv4cLg2Uy6t+7uhM5Bor343UJ38lzGe+puiM9jhgJsOkjG8HxmuFixA4HwFwDeohjIXgh4+Q6EWyL8RVV2IBD+4to7EOiyK8p2IJTTvATwiQo3XsqHBqh2KBD+MsYnwo7PeTWqZGT3crabBDuCzk28RU4oHuZ6SrtpBjW0FagTbvwKuHEz61a++cXVrJElQjK8kg2nNLLYSY5cBY5IxU5XOuWSCF4JBFKx0619yiVRvYqpprIfcR//q9muWdF6CH8N4C2KsHwt4OWt59YIv7pK6yH8dbVbD132+iqth/A3VGk9hL+xBv4mPqVb1boIv4bxiXE3VJHRtWw0CYzmlj8T3g8MZtex2WRokWEde/RGOsZ7qDMZeTf5eeDE9eCEtHncNXTVBlTFjJkYbwDGZn4U8xWMIxZFZHgjG05hY3o2U0ZsiaOrbuKrmhSBTPibAW9RRMDNgJcH8m0RfkuVQCb81tqBTJfdViWQCX9LlUAl/PYaOL1Sf6MQyITfyfhkRSqP8LcC3qbgv4vxqQmGGbJ7G9up9noR/nbA5yv8egfgCxT272S8JaFf72K7aYJf7wZc5dd7AFf59V7G8Y3tK+serAY7i8GmnC0Uu4NSZWvmDuX86q+LjOx2yNP3gadii7fkw3AqGd+vYDRFRr3Wspso7wZK6Q0Uoqzt3AeYaTpMPOfWNruHzWYquhnC7wW8RREPHwS8vJt5S4R/qEo3Q/iHa3czdNl9VboZwj9SpRsh/KP8C2SqboTwjzGeZLZJdh9nu4M626Qb3w83FmebQzlkNPwEGzZ0tkmOfBIcEWebjnD+LhF8CgjE2aZT8/xdonqAqZLMNsnuQbZTzTYJfwjwFkVYfhrw8tZze4R/pkrrIfyztVsPXfa5Kq2H8M9XaT2Ef4FX8qrWQ/gXGU/SesjuS2x3UFsP3fjLcGOx9Qz9iA0afoUNG9p6yJGvgiNi63GFA0uI4GtAILYet+aBJUT1dUg8Tk7w+L8BCaLy1kP4NwFvUYTltwAvbz13RPi3q7Qewr9Tu/XQZd+t0noI/16V1kP492vg9Ob104XWRfgPGcdll1a+VksXetL9RXpyHUGp0J1Ld6wd+FeZ7MT3I+bD9Vi+vlYX59aD0d0VlsobIvnyY/BFbIhD26PR8CdseCS/0EyiHTfC501bNq7Y3N/du6uwZoumaYYN1vQq9LnCuUaEP8x40xhJ/gjzNYPklx0Eydf2ZDaE6eLAG/Iq+R8Fv0T5fatSfnrf+TxeJqgE/DnjrSDgiTXToDtzPXtRtl8wy/Qxegy/ZL4Z4yDyfwW+yNIrIv/XXMQ+WpD+N4zj8U7Pqn+Ftq+vFHYPfhP+rrty3eHZuXz03Ia+12a4/W/h9s3cQMu/l6cZI18eJMPfseFseIW+t8Yr9N3B3nB99BCCEv3aJ70bXAr2nwXRuVmxQqz26vzgJYOEm6SX54VbHuwX6eMti2u9FE9XrqQrVw7ywfP4PTyPdg7QKRXR+Ieyq44cvgqf7R/hqmWKIfBP3BiOFWL6McbnJPxR7aqv+Vb2PYNB1RNeVqpyREWC/utxcFtKQXiaHzPpSIz/B4xD+QJfwZi4q32CiedJ4+kZ23Ztw/FU08Ca3hy+gDNGquf3F8bbxJQnXfVXvuo4xXyQ8L8B3qKIor8DXj4fvDPC/1FlPkj4P2vPB+myf1WZDxL+7yrzPcL/UwP/L78IrZoPRjgNuQP4WMwHie8I5mv0fJB8mQi+SKOiN3SQExpOYsPY80HdB+vJ/G75VEHyIxlvGiPJpzDfeJoPkl9TwS9RflOrlL+J98dPEwRsZrz++SCxHMUs0w/+1IZu3wK3F6c2pjVyakOG09hwBvidrtvvLYWhlPnIlMGI2Q5dhNK1ggvS2Q6eKZztQATTgaCZ/71UQVA+hpU7MoN5Zh46Qzm5PRPcFodyM+5QToxHA6M4lJsJh3IinsXEsxIP5WQ9mw+vOEZoyccwPkccyumqY/mqeYqhnPA5gLdUjoHT5gIOQzlNIAeuofr4lMFTlGkkHDiUZWDAnEOKbOvtiybmpWIhnw+LK+khULAampUy01YmDIxUytdSVsp2MtmsaaedtBFopmHaumaZQ0M9ldiPzkZsVG3eOXQiEuk64idnuEhe6+aB4zlWOpPOOp6RDi0t8FOuF4ZBKpPxTNtNGemUZgWBwzen+v2cqFfviYKGDqIh4o2XBd29+TD29027Rsq2g1A3XDdr6lnDNAMt8LJGxnZC3bbTXuDbljE0DtKWgNZojBgIKV4MTHjy0lrb7Wp5kUnbgel6hpEN0l4m8DJmNm1lw0D3rehRZA3b8DKhbWXYC9pjMKM3uvm2HtT8WFX73c3BVeXuph2aesYJtIxhpB0v8CxNC/WMHWqWY/mRE9mMb6dSLt+dtipMp2e+a0+xUCrlB0WYNDBI1vqinusYlqtnQt8NrTAIzDD6WpYVeJpuOJnQtH1fT2lhlm9Faf+j9o/b9caV4aTTTpAO/KwXzYuyaS/MpHQ/lfG0wDGzRpDR/XTWzqb4rrRpoTUVpPduL4Z9ff3FUK/3xq4dfSsva6UsX3dTTvR4jZQbpB0z7UTfNRukLEMzDN8Y/n30SNl0oTuV6wl3Du4crPfO6UhJO/Sjb5aNottzM5mU7dpZ3Q6CjJ92sobvpF1NC4aPs4+6jV745Yb97aiu24duxnOozWpRnxH4rhbaGct3TD1qS2b0naNuxYiiTR8+FCjqRjLDJ0qN8uZ2xtW80AhsPZvWLCvluqGjp30nlQoNP6NZGcu0bMP1hvcDRo+71B/d0Np/49G3ac3ysik3bZiZqNtKZT0nnfWMjGlZaS+l+WY6MELNTNve8L6qaOWXHziWcIniQSyht5CXLlXUCtQ1kJk12rxFnVuo65afdYIo1jOansnaGS3raWnHMjJayvAD29u/HWvChLns3cgAXUJvaZ9QcTRjZRKGeqJaXqUC19ItR4v6YSfj+G402KRsP2NkHCfMRIJZWlbXjeHe+DbZK3q3fJVKrhoKDhf/a7nq2qFr66bn6lkzFQ1NXjbSLkwZQVpLpTwrY+i6p6Xs7HAhU3TVbOiTpb1Fs4cdG+pplxgNdeoOUGvkSLOE+uJtSxOsKGvOCuMEZvS0fTNrRT24ZmuOr7lmmHaz0QSJHnE6FY2TdvRZOjs8O4t6kP2iKiYoS7SGfA8nDKxM5KeZNh075Tt+YIWWl8pEA1EYdZFeOohmIr6u/T+qd2/d", "eNoN1NvrD3Ycx/FvTH6f9/vrVMwFStPsYgoJF04hsZKV02KT4zbnQjGKku+Sw2pzmOYsRjMXjBxDttFQbMrEUCiHMENTs1keF49/4NmrV6VWt75Sq9vMVrbzLbvZxw8c4jDHOcFP/MxZznGRX7nM7/zBdW5xm7vc4z6PeMxfPOdvXvJvpVbeoAF1NKYJzWlBK1rTlrd4m3d4lw50ogtd6U4PetKbvvRnEO8xlGGM5ANGMZoxTGQSU5jKTGYzh7l8xkJqfM5yVvAlX/E169jIJjQtepadfMf37GEv+paD6FuOcgx9yyk0Lr+gbdG2aFu0LdoWbYu2Rduia9G1POQJupan6Fpe8A//8X+lFvUJkqY0401aom20QdtoR3u0DW2jI/pGZ/SNbmgc2kYf+jGAgQxG2xiOrqFrjGUcH/MJ05jOLLSNeegausYilqBvLEXfWMkXrGI132CzsQV9w2ZjB7uw29A3tA2bjSNoGiex2TiNzcZ5dI3f0DWucA194wY30TfuoG88wG7jT56hb+gb+oa+oW/ab9pvapwap8apcWqcGqfGqXHqmXqmjqlj2mn2Qse007TTtNMcwvuMwFbzQz5iPBP4lMnMwE7TPlPL1DLnswA9czGapr3mMuw1NU1N025T11zDWnTNDdhv6pvb0Df1TU3TH+R+DmC3qW/abeqbdps/Yrt5BvtNrfMCWqfWeQlbTr3zKpqn1qlz6px2nPqmb0h9U9/0DfkKjav1aIi+1Ub4iarOVZ2rvqLa8jXNDVC2");
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore = new HashMap();
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("fluxThrottling", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("getFluxString", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("connectableFluxExample", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$parallelFluxExample$6", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$combineStreams$4", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$combineStreams$3", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("backPressure1", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$combineStreams$5", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("concurrent", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("tuple4Example", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$fluxThrottling$1", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("parallelFluxExample", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("disposableExample", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$connectableFluxExample$0", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("pingOnSubscribe", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("lambda$concurrent$2", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("combineStreams", 0L);
org$unlogged$springwebfluxdemo$controller$FluxOpsController$unlogged$$mapStore.put("fluxListSubscribe", 0L);
}
}
Describe the bug
Project: unlogged-spring-webflux-demo Class: CronController and FluxOpsController
Dual methods are getting generated. But both of them have probes in them.
Reproduction steps
Expected behavior
The unprobed version of method should not have probes in it.
Additional context
No response