display.ex

untitled

defmodule MinigameWeb.CustomerLive do

  use MinigameWeb, :live_view
  # use KafkaEx.GenConsumer
  alias KafkaEx.Protocol.Fetch.Message
  require Logger



  def mount(_params, _session, socket) do
    # IO.inspect({__MODULE__, connected: connected?(socket), root_pid: socket.root_pid, self: self()})
    stream = KafkaEx.stream("foobar", 0)
    stream |> Stream.map(fn(msg) -> IO.puts(msg.value) end)
    socket = assign(socket, query: "", context: %{stream: stream})
    {:ok, socket}
  end

  def handle_info(:update, socket, context) do
    a = context.stream |> Stream.map(fn(msg) -> IO.puts(msg.value) end) |> Enum.to_list
    # IO.inspect(a)
    {:noreply, assign(socket, stream: a)}
  end

  def handle_info(%{event: "new_message", payload: state}, socket) do
    IO.inspect(state)
    {:noreply, assign(socket, state)}
  end

  def render(assigns) do
    IO.inspect(assigns)
    # a = assigns.context.def
    
    
    c = 1..3

    ~L"""
    <span class="weather">

        </span>
    <%= for user <- c do %>
    <pre>
    <%= user %>
    </pre>
    <% end %>

    """
    # stream = KafkaEx.stream("foobar", 0)
    # Enum.take(stream, 2)
    
  end

  defp have_stream(stream) do
    stream |> Enum.to_list
  end
end