RethinkDB.Connection one producer, three consumers

tester.exs

import RethinkDB.Query

require Logger

{:ok, pid} = RethinkDB.Connection.start_link

for i <- 1..3 do
  spawn_link fn ->
    Logger.debug "#{i} started"
    {:ok, feed} = table("users")
    |> changes
    |> RethinkDB.run(pid)

    feed
    |> Stream.each(fn change -> Logger.debug "#{i} => #{inspect change}" end)
    |> Stream.run
  end
end

1_000
|> Stream.interval
|> Enum.each(fn _i ->
  table("users")
  |> insert(%{name: "Lia", age: 23, in_relationship: true})
  |> RethinkDB.run(pid)
end)