From 055d0ad98e846dffd3f5143a494621aba210da80 Mon Sep 17 00:00:00 2001
From: Gilbert Wong <gilbertwong96@icloud.com>
Date: Thu, 28 Feb 2019 15:39:11 +0800
Subject: [PATCH] Fix typo

---
 src/emqx_client.erl | 30 +++++++++++++++---------------
 1 file changed, 15 insertions(+), 15 deletions(-)

diff --git a/src/emqx_client.erl b/src/emqx_client.erl
index 2b551be56..e29e50552 100644
--- a/src/emqx_client.erl
+++ b/src/emqx_client.erl
@@ -789,21 +789,21 @@ connected({call, From}, {publish, Msg = #mqtt_msg{qos = ?QOS_0}}, State) ->
 
 connected({call, From}, {publish, Msg = #mqtt_msg{qos = QoS}},
           State = #state{inflight = Inflight, last_packet_id = PacketId})
-     when (QoS =:= ?QOS_1); (QoS =:= ?QOS_2) ->
-     case emqx_inflight:is_full(Inflight) of
-         true ->
-            {keep_state, State, [{reply, From, {error, {PacketId, inflight_full}}}]};
-         false ->
-            Msg1 = Msg#mqtt_msg{packet_id = PacketId},
-            case send(Msg1, State) of
-                 {ok, NewState} ->
-                    Inflight1 = emqx_inflight:insert(PacketId, {publish, Msg1, os:timestamp()}, Inflight),
-                    {keep_state, ensure_retry_timer(NewState#state{inflight = Inflight1}),
-                     [{reply, From, {ok, PacketId}}]};
-                 {error, Reason} ->
-                     {stop_and_reply, Reason, [{reply, From, {error, {PacketId, Reason}}}]}
-             end
-     end;
+    when (QoS =:= ?QOS_1); (QoS =:= ?QOS_2) ->
+        case emqx_inflight:is_full(Inflight) of
+            true ->
+                {keep_state, State, [{reply, From, {error, {PacketId, inflight_full}}}]};
+            false ->
+                Msg1 = Msg#mqtt_msg{packet_id = PacketId},
+                case send(Msg1, State) of
+                    {ok, NewState} ->
+                        Inflight1 = emqx_inflight:insert(PacketId, {publish, Msg1, os:timestamp()}, Inflight),
+                        {keep_state, ensure_retry_timer(NewState#state{inflight = Inflight1}),
+                         [{reply, From, {ok, PacketId}}]};
+                    {error, Reason} ->
+                        {stop_and_reply, Reason, [{reply, From, {error, {PacketId, Reason}}}]}
+                end
+        end;
 
 connected({call, From}, UnsubReq = {unsubscribe, Properties, Topics},
           State = #state{last_packet_id = PacketId}) ->