examples/go-by-example-channels/channels.rb
#!/usr/bin/env ruby
$: << File.expand_path('../../../lib', __FILE__)
require 'concurrent-edge'
Channel = Concurrent::Channel
## Go by Example: Unbuffered Channel
# https://gobyexample.com/channels
messages = Channel.new # unbuffered
Channel.go do
messages.put 'ping'
end
msg = messages.take
puts msg
__END__
ping