Apply clang-format update fixes

Reviewed By: igorsugak

Differential Revision: D25861960

fbshipit-source-id: e3c39c080429058a58cdc66d45350e5d1420f98c

rsocket/RSocketResponder.h

@@ -126,24 +126,24 @@ class RSocketResponderAdapter : public RSocketResponderCore {
  std::shared_ptr<yarpl::flowable::Subscriber<Payload>> handleRequestChannel(
  Payload request,
  StreamId streamId,
- std::shared_ptr<yarpl::flowable::Subscriber<Payload>>
-  response) noexcept override;
+ std::shared_ptr<yarpl::flowable::Subscriber<Payload>> response) noexcept
+ override;
 
  /// Internal method for handling stream requests, not intended to be used
  /// by application code.
  void handleRequestStream(
  Payload request,
  StreamId streamId,
- std::shared_ptr<yarpl::flowable::Subscriber<Payload>>
-  response) noexcept override;
+ std::shared_ptr<yarpl::flowable::Subscriber<Payload>> response) noexcept
+ override;
 
  /// Internal method for handling request-response requests, not intended to be
  /// used by application code.
  void handleRequestResponse(
  Payload request,
  StreamId streamId,
- std::shared_ptr<yarpl::single::SingleObserver<Payload>>
-  response) noexcept override;
+ std::shared_ptr<yarpl::single::SingleObserver<Payload>> response) noexcept
+ override;
 
  void handleFireAndForget(Payload request, StreamId streamId) override;
  void handleMetadataPush(std::unique_ptr<folly::IOBuf> buf) override;

rsocket/benchmarks/StreamThroughputMemory.cpp

@@ -140,8 +140,8 @@ class Factory : public ConnectionFactory {
  ProtocolVersion,
  ResumeStatus /* unused */) override {
  return folly::via(worker_.getEventBase(), [this] {
- return ConnectedDuplexConnection{std::move(connection_),
-   *worker_.getEventBase()};
+ return ConnectedDuplexConnection{
+ std::move(connection_), *worker_.getEventBase()};
  });
  }
 

rsocket/examples/stream-observable-to-flowable/StreamObservableToFlowable_Server.cpp

@@ -73,8 +73,7 @@ class PushStreamRequestResponder : public rsocket::RSocketResponder {
  std::string payloadData = ss.str();
  s->onNext(Payload(payloadData, "metadata"));
  }
- })
- .detach();
+ }).detach();
  })
  ->toFlowable(BackpressureStrategy::DROP);
  }

rsocket/test/RequestChannelTest.cpp

@@ -442,13 +442,13 @@ TEST(RequestChannelTest, TestLargePayload) {
  return Payload(seedPayload.data->clone(), seedPayload.metadata->clone());
  };
 
- auto requests = yarpl::flowable::Flowable<Payload>::create(
-  [&](auto& subscriber, int64_t num) {
- while (num--) {
-  subscriber.onNext(makePayload());
-  }
-  })
-  ->take(3);
+ auto requests =
+ yarpl::flowable::Flowable<Payload>::create([&](auto& subscriber,
+  int64_t num) {
+ while (num--) {
+ subscriber.onNext(makePayload());
+ }
+ })->take(3);
 
  requester->requestChannel(std::move(requests))
  ->map([&](Payload p) {

rsocket/test/RequestResponseTest.cpp

@@ -66,8 +66,7 @@ class TestHandlerCancel : public rsocket::RSocketResponder {
  } else {
  // if not cancelled would do work and emit here
  }
- })
- .detach();
+ }).detach();
  });
  }
 

rsocket/transports/tcp/TcpConnectionAcceptor.cpp

@@ -91,24 +91,20 @@ void TcpConnectionAcceptor::start(OnDuplexConnectionAccept onAccept) {
 
  // The AsyncServerSocket needs to be accessed from the listener thread only.
  // This will propagate out any exceptions the listener throws.
- folly::via(
- serverThread_->getEventBase(),
- [this] {
- serverSocket_->bind(options_.address);
-
- for (auto const& callback : callbacks_) {
- serverSocket_->addAcceptCallback(
- callback.get(), callback->eventBase());
- }
-
- serverSocket_->listen(options_.backlog);
- serverSocket_->startAccepting();
-
- for (const auto& i : serverSocket_->getAddresses()) {
- VLOG(1) << "Listening on " << i.describe();
- }
- })
- .get();
+ folly::via(serverThread_->getEventBase(), [this] {
+ serverSocket_->bind(options_.address);
+
+ for (auto const& callback : callbacks_) {
+ serverSocket_->addAcceptCallback(callback.get(), callback->eventBase());
+ }
+
+ serverSocket_->listen(options_.backlog);
+ serverSocket_->startAccepting();
+
+ for (const auto& i : serverSocket_->getAddresses()) {
+ VLOG(1) << "Listening on " << i.describe();
+ }
+ }).get();
 }
 
 void TcpConnectionAcceptor::stop() {

rsocket/transports/tcp/TcpDuplexConnection.cpp

@@ -107,9 +107,8 @@ class TcpReaderWriter : public folly::AsyncTransportWrapper::WriteCallback,
  intrusive_ptr_release(this);
  }
 
- void writeErr(
- size_t,
- const folly::AsyncSocketException& exn) noexcept override {
+ void writeErr(size_t, const folly::AsyncSocketException& exn) noexcept
+ override {
  closeErr(folly::exception_wrapper{std::make_exception_ptr(exn), exn});
  intrusive_ptr_release(this);
  }