Toggle navigation
Home
java.util.function.Supplier to java.util.concurrent.Callable
No. of Instances - 27
No. of Commits - 5
No. of Projects - {'AxonFramework', 'keycloak', 'bootique', 'dropwizard', 'redisson'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
Add or Remove Method invocation
factoryMethod.get()
to
factoryMethod.call()
factoryMethod.get()
to
factoryMethod.call()
executeWithResult(aggregateFactory::get)
to
executeWithResultOrException(aggregateFactory::call)
super.reactive(new Callable<RFuture<R>>(){ volatile RFuture<R> future; @Override public RFuture<R> get(){ if (future == null) { synchronized (this) { if (future == null) { future=supplier.get(); } } } return future; } } )
to
super.reactive(new Callable<RFuture<R>>(){ volatile RFuture<R> future; @Override public RFuture<R> call() throws Exception { if (future == null) { synchronized (this) { if (future == null) { future=supplier.call(); } } } return future; } } )
Flux.<R>create(emitter -> { emitter.onRequest(n -> { RFuture<R> future=supplier.get(); future.onComplete((v,e) -> { if (e != null) { emitter.error(e); return; } emitter.onDispose(() -> { future.cancel(true); } ); if (v != null) { emitter.next(v); } emitter.complete(); } ); } ); } )
to
Flux.<R>create(emitter -> { emitter.onRequest(n -> { RFuture<R> future; try { future=supplier.call(); } catch ( Exception e) { emitter.error(e); return; } future.onComplete((v,e) -> { if (e != null) { emitter.error(e); return; } emitter.onDispose(() -> { future.cancel(true); } ); if (v != null) { emitter.next(v); } emitter.complete(); } ); } ); } )
this.http.<RegistrationResponse>post("/authz/protection/resource_set").authorizationBearer(this.pat.get()).json(JsonSerialization.writeValueAsBytes(resource)).response().json(RegistrationResponse.class)
to
this.http.<RegistrationResponse>post("/authz/protection/resource_set").authorizationBearer(this.pat.call()).json(JsonSerialization.writeValueAsBytes(resource)).response().json(RegistrationResponse.class)
this.http.<RegistrationResponse>put("/authz/protection/resource_set/" + resource.getId()).authorizationBearer(this.pat.get()).json(JsonSerialization.writeValueAsBytes(resource))
to
this.http.<RegistrationResponse>put("/authz/protection/resource_set/" + resource.getId()).authorizationBearer(this.pat.call()).json(JsonSerialization.writeValueAsBytes(resource))
this.http.<RegistrationResponse>get("/authz/protection/resource_set/" + id).authorizationBearer(this.pat.get()).response().json(RegistrationResponse.class)
to
this.http.<RegistrationResponse>get("/authz/protection/resource_set/" + id).authorizationBearer(this.pat.call()).response().json(RegistrationResponse.class)
this.http.<Set>get("/authz/protection/resource_set").authorizationBearer(this.pat.get()).param("filter",filter).response().json(Set.class)
to
this.http.<Set>get("/authz/protection/resource_set").authorizationBearer(this.pat.call()).param("filter",filter).response().json(Set.class)
this.http.<Set>get("/authz/protection/resource_set").authorizationBearer(this.pat.get()).response().json(Set.class)
to
this.http.<Set>get("/authz/protection/resource_set").authorizationBearer(this.pat.call()).response().json(Set.class)
this.http.delete("/authz/protection/resource_set/" + id).authorizationBearer(this.pat.get())
to
this.http.delete("/authz/protection/resource_set/" + id).authorizationBearer(this.pat.call())
this.http.<PermissionResponse>post("/authz/protection/permission").authorizationBearer(this.pat.get()).json(JsonSerialization.writeValueAsBytes(request)).response().json(PermissionResponse.class)
to
this.http.<PermissionResponse>post("/authz/protection/permission").authorizationBearer(this.pat.call()).json(JsonSerialization.writeValueAsBytes(request)).response().json(PermissionResponse.class)
Cascading Type Change (Similar)
Supplier<RFuture<R>>
to
Callable<RFuture<R>>