channel = Channel.new
pid = spawn_link fn ->
  # This line will block until the data is read
  Channel.put(channel, :some)
  Channel.put(channel, :data)
end
Process.alive?(pid) #=> true
Channel.get(channel) #=> :some
Process.alive?(pid) #=> true
Channel.get(channel) #=> :data
Process.alive?(pid) #=> false

import Supervisor.Spec
children = [
  worker(Channel, [[name: MyApp.Channel]])
]
{:ok, pid} = Supervisor.start_link(children, strategy: :one_for_one)
spawn_link fn ->
  # This line will block until some data is written to the channel
  data = Channel.get(MyApp.Channel)
  IO.puts "I read #{inspect data} from the channel."
end
Channel.put(MyApp.Channel, :data)

# Wraps the process name into a channel struct
# Works with PIDs too
my_channel = Channel.wrap(MyApp.Channel)
spawn_link fn ->
  # Blocks until all the values can be written
  Enum.into(1..10, my_channel)
end
# The buffer size means how many values I can put in a channel until it
# starts blocking.
other_channel = Channel.new(buffer_size: 10)
# The code bellow will block until the channel "my_channel" is closed.
for x <- my_channel, into: other_channel do
  x * 2
end

deps: [{:cspex, "~> x.x.x"}, ...]

use CSP