@@ -81,24 +81,24 @@ defmodule AutobahnClient do
8181 }
8282 end
8383
84- def recv ( % { ref: ref } = state ) do
84+ def recv ( % __MODULE__ { ref: ref } = state ) do
8585 { :ok , conn , messages } = Mint.WebSocket . stream ( state . conn , receive ( do: ( message -> message ) ) )
8686
87- % __MODULE__ {
87+ % {
8888 state
8989 | conn: conn ,
9090 buffer: join_data_frames ( messages , ref ) ,
9191 next: stop_if_done ( messages , ref )
9292 }
9393 end
9494
95- def decode_buffer ( state ) do
95+ def decode_buffer ( % __MODULE__ { } = state ) do
9696 { :ok , websocket , messages } = Mint.WebSocket . decode ( state . websocket , state . buffer )
9797
98- % __MODULE__ { state | messages: messages , buffer: << >> , websocket: websocket }
98+ % { state | messages: messages , buffer: << >> , websocket: websocket }
9999 end
100100
101- def loop ( state ) do
101+ def loop ( % __MODULE__ { } = state ) do
102102 case state |> decode_buffer |> handle_messages do
103103 % { next: :cont } = state ->
104104 loop ( recv ( state ) )
@@ -108,26 +108,26 @@ defmodule AutobahnClient do
108108 end
109109 end
110110
111- def handle_messages ( state ) do
111+ def handle_messages ( % __MODULE__ { } = state ) do
112112 Enum . reduce ( state . messages , state , fn message , state ->
113113 Logger . debug ( "Handling #{ inspect ( message , printable_limit: 30 ) } " )
114114 handle_message ( message , state )
115115 end )
116116 |> Map . put ( :messages , [ ] )
117117 end
118118
119- defp handle_message ( { :close , _code , _reason } , state ) do
119+ defp handle_message ( { :close , _code , _reason } , % __MODULE__ { } = state ) do
120120 close ( state , 1000 , "" )
121121 end
122122
123- defp handle_message ( { :ping , data } , state ) do
123+ defp handle_message ( { :ping , data } , % __MODULE__ { } = state ) do
124124 send ( state , { :pong , data } )
125125 end
126126
127127 # no-op on unsolicited pongs
128- defp handle_message ( { :pong , _body } , state ) , do: state
128+ defp handle_message ( { :pong , _body } , % __MODULE__ { } = state ) , do: state
129129
130- defp handle_message ( { :error , reason } , state ) do
130+ defp handle_message ( { :error , reason } , % __MODULE__ { } = state ) do
131131 Logger . debug ( "Closing the connection because of a protocol error: #{ inspect ( reason ) } " )
132132
133133 code =
@@ -139,7 +139,7 @@ defmodule AutobahnClient do
139139 close ( state , code , "" )
140140 end
141141
142- defp handle_message ( frame , state ) , do: send ( state , frame )
142+ defp handle_message ( frame , % __MODULE__ { } = state ) , do: send ( state , frame )
143143
144144 def send ( % __MODULE__ { sent_close?: true } = state , frame ) when is_close_frame ( frame ) do
145145 Logger . debug ( "Ignoring send of close" )
@@ -162,26 +162,26 @@ defmodule AutobahnClient do
162162 end
163163 end
164164
165- defp do_send ( state , frame , data ) do
165+ defp do_send ( % __MODULE__ { } = state , frame , data ) do
166166 case Mint.WebSocket . stream_request_body ( state . conn , state . ref , data ) do
167167 { :ok , conn } ->
168168 Logger . debug ( "Sent." )
169- % __MODULE__ { state | conn: conn , sent_close?: is_close_frame ( frame ) }
169+ % { state | conn: conn , sent_close?: is_close_frame ( frame ) }
170170
171171 { :error , conn , % Mint.TransportError { reason: :closed } } ->
172172 Logger . debug (
173173 "Could not send frame #{ inspect ( frame , printable_limit: 30 ) } because the connection is closed"
174174 )
175175
176176 { :ok , conn } = Mint.HTTP . close ( conn )
177- % __MODULE__ { state | conn: conn , next: :stop }
177+ % { state | conn: conn , next: :stop }
178178 end
179179 end
180180
181- defp close ( state , code , reason ) do
181+ defp close ( % __MODULE__ { } = state , code , reason ) do
182182 state = send ( state , { :close , code , reason } )
183183 { :ok , conn } = Mint.HTTP . close ( state . conn )
184- % __MODULE__ { state | conn: conn , next: :stop }
184+ % { state | conn: conn , next: :stop }
185185 end
186186
187187 defp join_data_frames ( messages , ref ) do
0 commit comments