pull/37079/head
Craig Tiller 8 months ago
parent 87862222cb
commit ea6cda4610
  1. 13
      test/core/transport/call_spine_benchmarks.h

@ -220,12 +220,13 @@ void BM_ClientToServerStreaming(benchmark::State& state) {
handler_done.WaitForNotification();
initiator_done.WaitForNotification();
}
call.initiator.SpawnInfallible("done", [&]() {
call.initiator.Cancel();
return Empty{};
});
call.handler.SpawnInfallible("done", [&]() {
call.handler.PushServerTrailingMetadata(
call.initiator.SpawnInfallible("done",
[initiator = call.initiator]() mutable {
initiator.Cancel();
return Empty{};
});
call.handler.SpawnInfallible("done", [handler = call.handler]() mutable {
handler.PushServerTrailingMetadata(
CancelledServerMetadataFromStatus(absl::CancelledError()));
return Empty{};
});

Loading…
Cancel
Save