Provide a thread-safe way for a Consumer to access its Registration

[reactor]

Provide a thread-safe way for a Consumer to access its Registration

[gembin]

But, if i need to cancel it only if some conditions are satisfied, not necessarily cancel after use, how to handle this?

for example:

new Consumer<Event<?>>() {
  @Override
  public void accept(Event<?> e) {
      if(some conditions are satisfied){
          registration.cancel();
      }
  }
})

[jbrisbin]

instead of registration.cancel(), throw a CancelConsumerException. The Dispatchers will catch this specifically and remove the registration.