first blush at elixir

message_bus.ex

defmodule MessageBus do

  # call any function that matches the listener
  # type is atom (eg: :hello)
  # message is string
  # listeners is list of tuples of functions
  # [ hello: fn(m) -> IO.puts m end, bye: fn(m) -> IO.puts m end, hello: fn(m) -> IO.puts "I will also do this crap" end ]""]
  def publish(type, message, listeners) do
    _publish(type, message, listeners)
  end

  def _publish( type, message, [] ), do: :nothing

  def _publish(type, message, [ { handler, fun } |t ]) when handler == type do
    fun.(message)
    _publish(type, message, t)
  end

  def _publish( type, message, [ { _, _} | t ] ) do
    _publish(type, message, t)
  end

end