f.(f) - timeout actor

func_rec.ex

defmodule Actors do
	def publish do
		publish(0)
	end

	def publish(count) do
		receive do
			{:in, pid} -> pid <- {:out, {{:msg, "demo"},{:count, count}}}
		end
		publish(count + 1)
	end
end

defmodule ActorsTest do
  def doIt do
  	actor = spawn_link(Actors, :publish, [])
	actor <- {:in, self()}
	actor <- {:in, self()}

  	f = fn(f) ->
	  	receive do
			{:out, {{:msg,msg},{:count,count}}} -> IO.puts "#{msg}, #{count}"
		after
			1000 -> actor <- {:in, self()}
 		end
		f.(f)
	end
	f.(f)
  end
end