diff --git a/src/protobuf-net.Grpc/Internal/Reshape.cs b/src/protobuf-net.Grpc/Internal/Reshape.cs index 35ab2ab5..a7b029a1 100644 --- a/src/protobuf-net.Grpc/Internal/Reshape.cs +++ b/src/protobuf-net.Grpc/Internal/Reshape.cs @@ -287,8 +287,8 @@ private static async IAsyncEnumerable ServerStreamingAsyncImpl IStreamAPI.ServerStreaming(Foo value, CallContext ct if (i == fault) { var faultTrailers = new Metadata(); - AddSum(ctx.ServerCallContext!.ResponseTrailers); AddSum(faultTrailers); throw new RpcException(new Status(StatusCode.Internal, "oops"), faultTrailers); } @@ -269,9 +268,9 @@ public class Foo } - public class NativeStreamTestsFixture : StreamTests + public class NativeStreamTests : StreamTests { - public NativeStreamTestsFixture(StreamTestsFixture fixture, ITestOutputHelper log) : base(10043, fixture, log) { } + public NativeStreamTests(StreamTestsFixture fixture, ITestOutputHelper log) : base(10043, fixture, log) { } protected override IAsyncDisposable CreateClient(out IStreamAPI client) { var channel = new Channel("localhost", Port, ChannelCredentials.Insecure); @@ -288,9 +287,9 @@ public DisposableChannel(Channel channel) } #if NETCOREAPP3_1 - public class ManagedStreamTestsFixture : StreamTests + public class ManagedStreamTests : StreamTests { - public ManagedStreamTestsFixture(StreamTestsFixture fixture, ITestOutputHelper log) : base(10044, fixture, log) { } + public ManagedStreamTests(StreamTestsFixture fixture, ITestOutputHelper log) : base(10044, fixture, log) { } protected override IAsyncDisposable CreateClient(out IStreamAPI client) { var http = global::Grpc.Net.Client.GrpcChannel.ForAddress($"http://localhost:{Port}");