77http_get_message = receive(do: (message -> message))
88{:ok, conn, [{:status, ^ref, status}, {:headers, ^ref, resp_headers}, {:done, ^ref}]} =
99 Mint.HTTP.stream(conn, http_get_message)
10- {:ok, conn, websocket} = Mint.WebSocket.new(conn, ref, status, req_headers, resp_headers)
10+ {:ok, conn, websocket} = Mint.WebSocket.new(conn, ref, status, resp_headers)
1111
1212{:ok, websocket, data} = Mint.WebSocket.encode(websocket, {:text, ~s[{"topic":"rooms:lobby","event":"phx_join","payload":{},"ref":1}]})
1313{:ok, conn} = Mint.HTTP.stream_request_body(conn, ref, data)
@@ -28,6 +28,6 @@ message = receive(do: (message -> message))
2828IO.inspect(messages)
2929
3030message = receive(do: (message -> message))
31- {:ok, conn , [{:data, ^ref, data}]} = Mint.HTTP.stream(conn, message)
32- {:ok, websocket , messages} = Mint.WebSocket.decode(websocket, data)
31+ {:ok, _conn , [{:data, ^ref, data}]} = Mint.HTTP.stream(conn, message)
32+ {:ok, _websocket , messages} = Mint.WebSocket.decode(websocket, data)
3333IO.inspect(messages)
0 commit comments