@@ -0,0 +1,1961 @@
+package io.scalecube.gateway.examples;%0A%0Aimport reactor.core.publisher.Flux;%0Aimport reactor.core.publisher.Mono;%0A%0Apublic class GreetingServiceCancelCallback implements GreetingService %7B%0A%0A  private final GreetingService greetingService = new GreetingServiceImpl();%0A  private final Runnable onCancel;%0A%0A  public GreetingServiceCancelCallback(Runnable onCancel) %7B%0A    this.onCancel = onCancel;%0A  %7D%0A%0A  @Override%0A  public Mono%3CString%3E one(String name) %7B%0A    return greetingService.one(name).doOnCancel(onCancel);%0A  %7D%0A%0A  @Override%0A  public Flux%3CLong%3E manyStream(Long cnt) %7B%0A    return greetingService.manyStream(cnt).doOnCancel(onCancel);%0A  %7D%0A%0A  @Override%0A  public Mono%3CString%3E failingOne(String name) %7B%0A    return greetingService.failingOne(name).doOnCancel(onCancel);%0A  %7D%0A%0A  @Override%0A  public Flux%3CString%3E many(String name) %7B%0A    return greetingService.many(name).doOnCancel(onCancel);%0A  %7D%0A%0A  @Override%0A  public Flux%3CString%3E failingMany(String name) %7B%0A    return greetingService.failingMany(name).doOnCancel(onCancel);%0A  %7D%0A%0A  @Override%0A  public Mono%3CGreetingResponse%3E pojoOne(GreetingRequest request) %7B%0A    return greetingService.pojoOne(request).doOnCancel(onCancel);%0A  %7D%0A%0A  @Override%0A  public Flux%3CGreetingResponse%3E pojoMany(GreetingRequest request) %7B%0A    return greetingService.pojoMany(request).doOnCancel(onCancel);%0A  %7D%0A%0A  @Override%0A  public Mono%3CString%3E emptyOne(String name) %7B%0A    return greetingService.emptyOne(name).doOnCancel(onCancel);%0A  %7D%0A%0A  @Override%0A  public Flux%3CString%3E emptyMany(String name) %7B%0A    return greetingService.emptyMany(name).doOnCancel(onCancel);%0A  %7D%0A%0A  @Override%0A  public Mono%3CString%3E neverOne(String name) %7B%0A    return greetingService.neverOne(name).doOnCancel(onCancel);%0A  %7D%0A%0A  @Override%0A  public Mono%3CString%3E delayOne(String name) %7B%0A    return greetingService.delayOne(name).doOnCancel(onCancel);%0A  %7D%0A%0A  @Override%0A  public Flux%3CString%3E delayMany(String name) %7B%0A    return greetingService.delayMany(name).doOnCancel(onCancel);%0A  %7D%0A%7D%0A

Revert deleting of GreetingServiceCancelCallback