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