Adjusting code

src/emqx_connection.erl

@@ -135,7 +135,7 @@ init([Transport, RawSocket, Options]) ->
             ProtoState = emqx_protocol:init(#{peername => Peername,
                                               sockname => Sockname,
                                               peercert => Peercert,
-                                              sendfun  => SendFun}, [Options ++ [{socktype, SockType}]]),
+                                              sendfun  => SendFun}, Options ++ [{socktype, SockType}]),
             ParserState = emqx_protocol:parser(ProtoState),
             GcPolicy = emqx_zone:get_env(Zone, force_gc_policy, false),
             GcState = emqx_gc:init(GcPolicy),

src/emqx_ws_connection.erl

@@ -126,7 +126,7 @@ websocket_init(#state{request = Req, options = Options}) ->
     ProtoState = emqx_protocol:init(#{peername => Peername,
                                       sockname => Sockname,
                                       peercert => Peercert,
-                                      sendfun  => send_fun(self())}, [Options ++ [{socktype, websocket}]]),
+                                      sendfun  => send_fun(self())}, Options ++ [{socktype, websocket}]),
     ParserState = emqx_protocol:parser(ProtoState),
     Zone = proplists:get_value(zone, Options),
     EnableStats = emqx_zone:get_env(Zone, enable_stats, true),