pp: Wrap inform in coroutine::lambda

Fix redpanda-data#6903 Signed-off-by: Ben Pope <ben@redpanda.com>
BenPope · Nov 2, 2022 · b46f8fb · b46f8fb
1 parent a237842
commit b46f8fb
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 10 deletions.
diff --git a/src/v/pandaproxy/rest/proxy.cc b/src/v/pandaproxy/rest/proxy.cc
@@ -213,11 +213,12 @@ ss::future<> proxy::mitigate_error(std::exception_ptr eptr) {
 
 ss::future<> proxy::inform(model::node_id id) {
     vlog(plog.trace, "inform: {}", id);
-    const auto do_inform = [this](model::node_id n) -> ss::future<> {
-        auto& fe = _controller->get_ephemeral_credential_frontend().local();
-        auto ec = co_await fe.inform(n, principal);
-        vlog(plog.info, "Informed: broker: {}, ec: {}", n, ec);
-    };
+    const auto do_inform = ss::coroutine::lambda(
+      [this](model::node_id n) -> ss::future<> {
+          auto& fe = _controller->get_ephemeral_credential_frontend().local();
+          auto ec = co_await fe.inform(n, principal);
+          vlog(plog.info, "Informed: broker: {}, ec: {}", n, ec);
+      });
 
     // Inform a particular node
     if (id != kafka::client::unknown_node_id) {

diff --git a/src/v/pandaproxy/schema_registry/service.cc b/src/v/pandaproxy/schema_registry/service.cc
@@ -217,11 +217,12 @@ ss::future<> service::mitigate_error(std::exception_ptr eptr) {
 
 ss::future<> service::inform(model::node_id id) {
     vlog(plog.warn, "inform: {}", id);
-    const auto do_inform = [this](model::node_id n) -> ss::future<> {
-        auto& fe = _controller->get_ephemeral_credential_frontend().local();
-        auto ec = co_await fe.inform(n, principal);
-        vlog(plog.warn, "Informed: broker: {}, ec: {}", n, ec);
-    };
+    const auto do_inform = ss::coroutine::lambda(
+      [this](model::node_id n) -> ss::future<> {
+          auto& fe = _controller->get_ephemeral_credential_frontend().local();
+          auto ec = co_await fe.inform(n, principal);
+          vlog(plog.warn, "Informed: broker: {}, ec: {}", n, ec);
+      });
 
     // Inform a particular node
     if (id != kafka::client::unknown_node_id) {