Merge branch 'cg-channel-filter-api' into cg-cancel-nicely

pull/35212/head
Craig Tiller 1 year ago
commit 411ede654b
  1. 15
      src/core/lib/channel/promise_based_filter.h

@ -321,11 +321,11 @@ inline auto RunCall(
}
template <typename Derived>
inline auto RunCall(ServerMetadataHandle (Derived::Call::*fn)(
ClientMetadata& md, Derived* channel),
CallArgs call_args, NextPromiseFactory next_promise_factory,
FilterCallData<Derived>* call_data)
-> ArenaPromise<ServerMetadataHandle> {
inline auto RunCall(
ServerMetadataHandle (Derived::Call::*fn)(ClientMetadata& md,
Derived* channel),
CallArgs call_args, NextPromiseFactory next_promise_factory,
FilterCallData<Derived>* call_data) -> ArenaPromise<ServerMetadataHandle> {
GPR_DEBUG_ASSERT(fn == &Derived::Call::OnClientInitialMetadata);
auto return_md = call_data->call.OnClientInitialMetadata(
*call_args.client_initial_metadata, call_data->channel);
@ -359,7 +359,7 @@ inline void InterceptClientInitialMetadata(
Derived* channel, CallSpineInterface* call_spine) {
GPR_DEBUG_ASSERT(fn == &Derived::Call::OnClientInitialMetadata);
call_spine->client_initial_metadata().receiver.InterceptAndMap(
[call](ClientMetadataHandle md) -> absl::optional<ClientMetadataHandle> {
[call](ClientMetadataHandle md) {
call->OnClientInitialMetadata(*md);
return md;
});
@ -372,8 +372,7 @@ inline void InterceptClientInitialMetadata(
CallSpineInterface* call_spine) {
GPR_DEBUG_ASSERT(fn == &Derived::Call::OnClientInitialMetadata);
call_spine->client_initial_metadata().receiver.InterceptAndMap(
[call, channel](
ClientMetadataHandle md) -> absl::optional<ClientMetadataHandle> {
[call, channel](ClientMetadataHandle md) {
call->OnClientInitialMetadata(*md, channel);
return md;
});

Loading…
Cancel
Save