Lint fixes for rsocket/src (#421)

Author: alexmalyshev

src/ConnectionAutomaton.cpp

@@ -609,7 +609,8 @@ void ConnectionAutomaton::handleStreamFrame(
                                    std::move(serializedFrame))) {
         return;
       }
-      automaton->handleError(std::runtime_error(frameError.payload_.moveDataToString()));
+      automaton->handleError(
+          std::runtime_error(frameError.payload_.moveDataToString()));
       break;
     }
     case FrameType::REQUEST_CHANNEL:
@@ -887,8 +888,9 @@ void ConnectionAutomaton::setFrameSerializer(
   frameSerializer_ = std::move(frameSerializer);
 }
 
-void ConnectionAutomaton::setUpFrame(std::shared_ptr<FrameTransport> frameTransport,
-                                     ConnectionSetupPayload setupPayload) {
+void ConnectionAutomaton::setUpFrame(
+    std::shared_ptr<FrameTransport> frameTransport,
+    ConnectionSetupPayload setupPayload) {
   auto protocolVersion = getSerializerProtocolVersion();
 
   Frame_SETUP frame(

src/ConnectionAutomaton.h

@@ -195,9 +195,10 @@ class ConnectionAutomaton final
 
   void metadataPush(std::unique_ptr<folly::IOBuf> metadata);
 
-  void tryClientResume(const ResumeIdentificationToken& token,
-                         std::shared_ptr<FrameTransport> frameTransport,
-                         std::unique_ptr<ClientResumeStatusCallback> resumeCallback);
+  void tryClientResume(
+      const ResumeIdentificationToken& token,
+      std::shared_ptr<FrameTransport> frameTransport,
+      std::unique_ptr<ClientResumeStatusCallback> resumeCallback);
 
   void setFrameSerializer(std::unique_ptr<FrameSerializer>);
 

src/ReactiveSocket.cpp

@@ -235,7 +235,8 @@ void ReactiveSocket::tryClientResume(
   debugCheckCorrectExecutor();
   checkNotClosed();
   CHECK(frameTransport && !frameTransport->isClosed());
-  connection_->tryClientResume(token, std::move(frameTransport), std::move(resumeCallback));
+  connection_->tryClientResume(
+      token, std::move(frameTransport), std::move(resumeCallback));
 }
 
 bool ReactiveSocket::tryResumeServer(

test/ReactiveSocketTest.cpp

@@ -1551,4 +1551,4 @@ TEST_F(ReactiveSocketEmptyPayloadTest, RequestChannel) {
         }
       }));
   clientOutput->onSubscribe(clientOutputSub);
-}
+}