Skip to content

Commit

Permalink
[pre-commit.ci] auto fixes from pre-commit.com hooks
Browse files Browse the repository at this point in the history
for more information, see https://pre-commit.ci
  • Loading branch information
pre-commit-ci[bot] committed May 25, 2024
1 parent 160baea commit 5803244
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion src/extensions/rppgrpc/rppgrpc/client_reactor.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -130,7 +130,7 @@ namespace rppgrpc::details
if (m_write.size() == 1)
Base::StartWrite(&m_write.front()); },
[this](const std::exception_ptr&) {
// Base::StartWritesDone();
// Base::StartWritesDone();
context_.TryCancel();

Check failure on line 134 in src/extensions/rppgrpc/rppgrpc/client_reactor.hpp

View workflow job for this annotation

GitHub Actions / tests ci-macos Release

use of undeclared identifier 'context_'

Check failure on line 134 in src/extensions/rppgrpc/rppgrpc/client_reactor.hpp

View workflow job for this annotation

GitHub Actions / Sanitize - lsan

use of undeclared identifier 'context_'
},
[this]() {
Expand Down
6 changes: 3 additions & 3 deletions src/extensions/rppgrpc/rppgrpc/server_reactor.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,7 @@ namespace rppgrpc::details
using Base = grpc::ServerWriteReactor<Response>;

public:
template<rpp::constraint::observable_of_type<Response> Observable, rpp::constraint::decayed_same_as<Observer> TObserver>
template<rpp::constraint::observable_of_type<Response> Observable, rpp::constraint::decayed_same_as<Observer> TObserver>
requires (!rpp::constraint::decayed_same_as<Observable, server_write_reactor<Response, Observer>>)
server_write_reactor(const Observable& messages, TObserver&& observer)
: m_observer{std::forward<TObserver>(observer)}
Expand Down Expand Up @@ -164,8 +164,8 @@ namespace rppgrpc::details

void OnCancel() override
{
m_observer.on_error(std::make_exception_ptr(rppgrpc::utils::reactor_failed{"OnCancel called"}));
Base::Finish(grpc::Status::CANCELLED);
m_observer.on_error(std::make_exception_ptr(rppgrpc::utils::reactor_failed{"OnCancel called"}));
Base::Finish(grpc::Status::CANCELLED);
}

private:
Expand Down

0 comments on commit 5803244

Please sign in to comment.