Contents

# frozen_string_literal: true

require 'bundler/setup'
require 'polyphony'

async def sleep_and_cancel
  puts "#{Time.now} going to sleep with cancel..."
  cancel_after(1) do
    puts "#{Time.now} outer cancel scope"
    cancel_after(10) do
      puts "#{Time.now} inner cancel scope"
      sleep 60
    rescue Exception => e
      puts "#{Time.now} inner scope got error: #{e}"
      raise e
    end
  rescue Exception => e
    puts "#{Time.now} outer scope got error: #{e}"
  end
ensure
  puts "#{Time.now} woke up"
end

async def sleep_and_move_on
  puts "#{Time.now} going to sleep with move_on..."
  move_on_after(1) do
    puts "#{Time.now} outer cancel scope"
    move_on_after(10) do
      puts "#{Time.now} inner cancel scope"
      sleep 60
      puts "#{Time.now} inner scope done"
    end
    puts "#{Time.now} outer scope done"
  end
  puts "#{Time.now} woke up"
end

sleep_and_cancel.await
puts
sleep_and_move_on.await

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
polyphony-0.19	examples/core/nested_cancel.rb
polyphony-0.17	examples/core/nested_cancel.rb
polyphony-0.16	examples/core/nested_cancel.rb