Method: IOPromise::ExecutorContext#register

Defined in:
lib/iopromise/executor_context.rb

#register(promise) ⇒ Object



30
31
32
33
# File 'lib/iopromise/executor_context.rb', line 30

def register(promise)
  @pending_registrations << promise
  IOPromise::CancelContext.current&.subscribe(promise)
end