Merge pull request #128 from lehecka/format

fixing formatting by running devtools/format_all.sh

Author: lehecka

src/automata/RequestResponseRequester.h

@@ -2,8 +2,8 @@
 
 #pragma once
 
-#include <iosfwd>
 #include <folly/Optional.h>
+#include <iosfwd>
 
 #include <reactive-streams/utilities/SmartPointers.h>
 #include "src/Frame.h"
@@ -27,7 +27,6 @@ enum class StreamCompletionSignal;
 /// Implementation of stream automaton that represents a RequestResponse
 /// requester
 class RequestResponseRequesterBase : public MixinTerminator {
-
  public:
   using MixinTerminator::MixinTerminator;
 
@@ -74,7 +73,7 @@ class RequestResponseRequesterBase : public MixinTerminator {
   reactivestreams::SubscriberPtr<Subscriber<Payload>> consumingSubscriber_;
 };
 
-using RequestResponseRequester = SourceIfMixin <
-    StreamIfMixin<LoggingMixin<ExecutorMixin<LoggingMixin<
+using RequestResponseRequester =
+    SourceIfMixin<StreamIfMixin<LoggingMixin<ExecutorMixin<LoggingMixin<
         MemoryMixin<LoggingMixin<RequestResponseRequesterBase>>>>>>>;
 }

src/automata/RequestResponseResponder.cpp

@@ -35,7 +35,6 @@ void RequestResponseResponderBase::onComplete() {
   }
 }
 
-
 void RequestResponseResponderBase::onError(folly::exception_wrapper ex) {
   switch (state_) {
     case State::RESPONDING: {
@@ -75,8 +74,7 @@ void RequestResponseResponderBase::onNextFrame(Frame_CANCEL&& frame) {
 }
 
 std::ostream& RequestResponseResponderBase::logPrefix(std::ostream& os) {
-  return os << "RequestResponseResponder(" << &connection_ << ", "
-            << streamId_ << "): ";
+  return os << "RequestResponseResponder(" << &connection_ << ", " << streamId_
+            << "): ";
 }
-
 }

src/automata/RequestResponseResponder.h

@@ -28,7 +28,7 @@ enum class StreamCompletionSignal;
 /// responder
 class RequestResponseResponderBase
     : public LoggingMixin<PublisherMixin<Frame_RESPONSE, MixinTerminator>> {
-  using Base =  LoggingMixin<PublisherMixin<Frame_RESPONSE, MixinTerminator>>;
+  using Base = LoggingMixin<PublisherMixin<Frame_RESPONSE, MixinTerminator>>;
 
  public:
   using Base::Base;
@@ -60,7 +60,7 @@ class RequestResponseResponderBase
     RESPONDING,
     CLOSED,
   } state_{State::RESPONDING};
- };
+};
 
 using RequestResponseResponder =
     SinkIfMixin<StreamIfMixin<LoggingMixin<ExecutorMixin<LoggingMixin<

test/ReactiveSocketTest.cpp

@@ -451,9 +451,9 @@ TEST(ReactiveSocketTest, RequestResponse) {
   // had COMPELTE flag set
   EXPECT_CALL(clientInput, onComplete_()).InSequence(s);
 
-  EXPECT_CALL(serverOutputSub, cancel_()).InSequence(s).WillOnce(Invoke([&]() {
-    serverOutput->onComplete();
-  }));
+  EXPECT_CALL(serverOutputSub, cancel_())
+      .InSequence(s)
+      .WillOnce(Invoke([&]() { serverOutput->onComplete(); }));
 
   // Kick off the magic.
   clientSock->requestResponse(Payload(originalPayload->clone()), clientInput);