Make GenericInterceptor internal for now
Also change `*Arbitrator` to `*Hooks`.
diff --git a/src/csharp/Grpc.Core.Tests/Interceptors/ClientInterceptorTest.cs b/src/csharp/Grpc.Core.Tests/Interceptors/ClientInterceptorTest.cs
index ca7677c..0ec2d84 100644
--- a/src/csharp/Grpc.Core.Tests/Interceptors/ClientInterceptorTest.cs
+++ b/src/csharp/Grpc.Core.Tests/Interceptors/ClientInterceptorTest.cs
@@ -71,17 +71,14 @@
var stringBuilder = new StringBuilder();
var callInvoker = helper.GetChannel().Intercept(metadata =>
{
- metadata = metadata ?? new Metadata();
stringBuilder.Append("interceptor1");
return metadata;
}).Intercept(metadata =>
{
- metadata = metadata ?? new Metadata();
stringBuilder.Append("interceptor2");
return metadata;
}).Intercept(metadata =>
{
- metadata = metadata ?? new Metadata();
stringBuilder.Append("interceptor3");
return metadata;
});
@@ -91,14 +88,14 @@
private class CountingInterceptor : GenericInterceptor
{
- protected override ClientCallArbitrator<TRequest, TResponse> InterceptCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TResponse> context, bool clientStreaming, bool serverStreaming, TRequest request)
+ protected override ClientCallHooks<TRequest, TResponse> InterceptCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TResponse> context, bool clientStreaming, bool serverStreaming, TRequest request)
{
if (!clientStreaming)
{
return null;
}
int counter = 0;
- return new ClientCallArbitrator<TRequest, TResponse>
+ return new ClientCallHooks<TRequest, TResponse>
{
OnRequestMessage = m => { counter++; return m; },
OnUnaryResponse = x => (TResponse)(object)counter.ToString() // Cast to object first is needed to satisfy the type-checker
@@ -112,14 +109,14 @@
var helper = new MockServiceHelper(Host);
helper.ClientStreamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStream, context) =>
{
- string result = "";
- await requestStream.ForEachAsync((request) =>
+ var stringBuilder = new StringBuilder();
+ await requestStream.ForEachAsync(request =>
{
- result += request;
+ stringBuilder.Append(request);
return TaskUtils.CompletedTask;
});
await Task.Delay(100);
- return result;
+ return stringBuilder.ToString();
});
var callInvoker = helper.GetChannel().Intercept(new CountingInterceptor());
diff --git a/src/csharp/Grpc.Core.Tests/Interceptors/ServerInterceptorTest.cs b/src/csharp/Grpc.Core.Tests/Interceptors/ServerInterceptorTest.cs
index fbace51..57dd68b 100644
--- a/src/csharp/Grpc.Core.Tests/Interceptors/ServerInterceptorTest.cs
+++ b/src/csharp/Grpc.Core.Tests/Interceptors/ServerInterceptorTest.cs
@@ -44,10 +44,10 @@
this.header = new Metadata.Entry(key, value);
}
- protected override Task<ServerCallArbitrator<TRequest, TResponse>> InterceptHandler<TRequest, TResponse>(ServerCallContext context, bool clientStreaming, bool serverStreaming, TRequest request)
+ protected override Task<ServerCallHooks<TRequest, TResponse>> InterceptHandler<TRequest, TResponse>(ServerCallContext context, bool clientStreaming, bool serverStreaming, TRequest request)
{
context.RequestHeaders.Add(header);
- return Task.FromResult<ServerCallArbitrator<TRequest, TResponse>>(null);
+ return Task.FromResult<ServerCallHooks<TRequest, TResponse>>(null);
}
public Metadata.Entry Header
@@ -87,10 +87,10 @@
this.action = action;
}
- protected override Task<ServerCallArbitrator<TRequest, TResponse>> InterceptHandler<TRequest, TResponse>(ServerCallContext context, bool clientStreaming, bool serverStreaming, TRequest request)
+ protected override Task<ServerCallHooks<TRequest, TResponse>> InterceptHandler<TRequest, TResponse>(ServerCallContext context, bool clientStreaming, bool serverStreaming, TRequest request)
{
action();
- return Task.FromResult<ServerCallArbitrator<TRequest, TResponse>>(null);
+ return Task.FromResult<ServerCallHooks<TRequest, TResponse>>(null);
}
}
diff --git a/src/csharp/Grpc.Core/ClientBase.cs b/src/csharp/Grpc.Core/ClientBase.cs
index f978d08..4bb06ed 100644
--- a/src/csharp/Grpc.Core/ClientBase.cs
+++ b/src/csharp/Grpc.Core/ClientBase.cs
@@ -161,12 +161,12 @@
this.interceptor = GrpcPreconditions.CheckNotNull(interceptor, "interceptor");
}
- protected override ClientCallArbitrator<TRequest, TResponse> InterceptCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TResponse> context, bool clientStreaming, bool serverStreaming, TRequest request)
+ protected override ClientCallHooks<TRequest, TResponse> InterceptCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TResponse> context, bool clientStreaming, bool serverStreaming, TRequest request)
{
var newHostAndCallOptions = interceptor(context.Method, context.Host, context.Options);
- return new ClientCallArbitrator<TRequest, TResponse>
+ return new ClientCallHooks<TRequest, TResponse>
{
- Context = new ClientInterceptorContext<TRequest, TResponse>(context.Method, newHostAndCallOptions.Item1, newHostAndCallOptions.Item2)
+ ContextOverride = new ClientInterceptorContext<TRequest, TResponse>(context.Method, newHostAndCallOptions.Item1, newHostAndCallOptions.Item2)
};
}
}
diff --git a/src/csharp/Grpc.Core/Interceptors/CallInvokerExtensions.cs b/src/csharp/Grpc.Core/Interceptors/CallInvokerExtensions.cs
index f1835f6..1c0831a 100644
--- a/src/csharp/Grpc.Core/Interceptors/CallInvokerExtensions.cs
+++ b/src/csharp/Grpc.Core/Interceptors/CallInvokerExtensions.cs
@@ -113,11 +113,12 @@
this.interceptor = GrpcPreconditions.CheckNotNull(interceptor, "interceptor");
}
- protected override ClientCallArbitrator<TRequest, TResponse> InterceptCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TResponse> context, bool clientStreaming, bool serverStreaming, TRequest request)
+ protected override ClientCallHooks<TRequest, TResponse> InterceptCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TResponse> context, bool clientStreaming, bool serverStreaming, TRequest request)
{
- return new ClientCallArbitrator<TRequest, TResponse>
+ var metadata = context.Options.Headers ?? new Metadata();
+ return new ClientCallHooks<TRequest, TResponse>
{
- Context = new ClientInterceptorContext<TRequest, TResponse>(context.Method, context.Host, context.Options.WithHeaders(interceptor(context.Options.Headers)))
+ ContextOverride = new ClientInterceptorContext<TRequest, TResponse>(context.Method, context.Host, context.Options.WithHeaders(interceptor(metadata))),
};
}
}
diff --git a/src/csharp/Grpc.Core/Interceptors/GenericInterceptor.cs b/src/csharp/Grpc.Core/Interceptors/GenericInterceptor.cs
index ed90ded..7ee649e 100644
--- a/src/csharp/Grpc.Core/Interceptors/GenericInterceptor.cs
+++ b/src/csharp/Grpc.Core/Interceptors/GenericInterceptor.cs
@@ -27,27 +27,27 @@
/// Provides a base class for generic interceptor implementations that raises
/// events and hooks to control the RPC lifecycle.
/// </summary>
- public abstract class GenericInterceptor : Interceptor
+ internal abstract class GenericInterceptor : Interceptor
{
/// <summary>
/// Provides hooks through which an invocation should be intercepted.
/// </summary>
- public sealed class ClientCallArbitrator<TRequest, TResponse>
+ public sealed class ClientCallHooks<TRequest, TResponse>
where TRequest : class
where TResponse : class
{
- internal ClientCallArbitrator<TRequest, TResponse> Freeze()
+ internal ClientCallHooks<TRequest, TResponse> Freeze()
{
- return (ClientCallArbitrator<TRequest, TResponse>)MemberwiseClone();
+ return (ClientCallHooks<TRequest, TResponse>)MemberwiseClone();
}
/// <summary>
/// Override the context for the outgoing invocation.
/// </summary>
- public ClientInterceptorContext<TRequest, TResponse> Context { get; set; }
+ public ClientInterceptorContext<TRequest, TResponse>? ContextOverride { get; set; }
/// <summary>
/// Override the request for the outgoing invocation for non-client-streaming invocations.
/// </summary>
- public TRequest UnaryRequest { get; set; }
+ public TRequest UnaryRequestOverride { get; set; }
/// <summary>
/// Delegate that intercepts a response from a non-server-streaming invocation and optionally overrides it.
/// </summary>
@@ -73,7 +73,7 @@
/// <summary>
/// Intercepts an outgoing call from the client side.
/// Derived classes that intend to intercept outgoing invocations from the client side should
- /// override this and return the appropriate hooks in the form of a ClientCallArbitrator instance.
+ /// override this and return the appropriate hooks in the form of a ClientCallHooks instance.
/// </summary>
/// <param name="context">The context of the outgoing invocation.</param>
/// <param name="clientStreaming">True if the invocation is client-streaming.</param>
@@ -82,10 +82,10 @@
/// <typeparam name="TRequest">Request message type for the current invocation.</typeparam>
/// <typeparam name="TResponse">Response message type for the current invocation.</typeparam>
/// <returns>
- /// The derived class should return an instance of ClientCallArbitrator to control the trajectory
+ /// The derived class should return an instance of ClientCallHooks to control the trajectory
/// as they see fit, or null if it does not intend to pursue the invocation any further.
/// </returns>
- protected virtual ClientCallArbitrator<TRequest, TResponse> InterceptCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TResponse> context, bool clientStreaming, bool serverStreaming, TRequest request)
+ protected virtual ClientCallHooks<TRequest, TResponse> InterceptCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TResponse> context, bool clientStreaming, bool serverStreaming, TRequest request)
where TRequest : class
where TResponse : class
{
@@ -95,18 +95,18 @@
/// <summary>
/// Provides hooks through which a server-side handler should be intercepted.
/// </summary>
- public sealed class ServerCallArbitrator<TRequest, TResponse>
+ public sealed class ServerCallHooks<TRequest, TResponse>
where TRequest : class
where TResponse : class
{
- internal ServerCallArbitrator<TRequest, TResponse> Freeze()
+ internal ServerCallHooks<TRequest, TResponse> Freeze()
{
- return (ServerCallArbitrator<TRequest, TResponse>)MemberwiseClone();
+ return (ServerCallHooks<TRequest, TResponse>)MemberwiseClone();
}
/// <summary>
/// Override the request for the outgoing invocation for non-client-streaming invocations.
/// </summary>
- public TRequest UnaryRequest { get; set; }
+ public TRequest UnaryRequestOverride { get; set; }
/// <summary>
/// Delegate that intercepts a response from a non-server-streaming invocation and optionally overrides it.
/// </summary>
@@ -132,7 +132,7 @@
/// <summary>
/// Intercepts an incoming service handler invocation on the server side.
/// Derived classes that intend to intercept incoming handlers on the server side should
- /// override this and return the appropriate hooks in the form of a ServerCallArbitrator instance.
+ /// override this and return the appropriate hooks in the form of a ServerCallHooks instance.
/// </summary>
/// <param name="context">The context of the incoming invocation.</param>
/// <param name="clientStreaming">True if the invocation is client-streaming.</param>
@@ -141,14 +141,14 @@
/// <typeparam name="TRequest">Request message type for the current invocation.</typeparam>
/// <typeparam name="TResponse">Response message type for the current invocation.</typeparam>
/// <returns>
- /// The derived class should return an instance of ServerCallArbitrator to control the trajectory
+ /// The derived class should return an instance of ServerCallHooks to control the trajectory
/// as they see fit, or null if it does not intend to pursue the invocation any further.
/// </returns>
- protected virtual Task<ServerCallArbitrator<TRequest, TResponse>> InterceptHandler<TRequest, TResponse>(ServerCallContext context, bool clientStreaming, bool serverStreaming, TRequest request)
+ protected virtual Task<ServerCallHooks<TRequest, TResponse>> InterceptHandler<TRequest, TResponse>(ServerCallContext context, bool clientStreaming, bool serverStreaming, TRequest request)
where TRequest : class
where TResponse : class
{
- return Task.FromResult<ServerCallArbitrator<TRequest, TResponse>>(null);
+ return Task.FromResult<ServerCallHooks<TRequest, TResponse>>(null);
}
/// <summary>
@@ -156,13 +156,13 @@
/// </summary>
public override TResponse BlockingUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> context, BlockingUnaryCallContinuation<TRequest, TResponse> continuation)
{
- var arbitrator = InterceptCall(context, false, false, request)?.Freeze();
- context = arbitrator?.Context ?? context;
- request = arbitrator?.UnaryRequest ?? request;
+ var hooks = InterceptCall(context, false, false, request)?.Freeze();
+ context = hooks?.ContextOverride ?? context;
+ request = hooks?.UnaryRequestOverride ?? request;
var response = continuation(request, context);
- if (arbitrator?.OnUnaryResponse != null)
+ if (hooks?.OnUnaryResponse != null)
{
- response = arbitrator.OnUnaryResponse(response);
+ response = hooks.OnUnaryResponse(response);
}
return response;
}
@@ -172,13 +172,13 @@
/// </summary>
public override AsyncUnaryCall<TResponse> AsyncUnaryCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> context, AsyncUnaryCallContinuation<TRequest, TResponse> continuation)
{
- var arbitrator = InterceptCall(context, false, false, request)?.Freeze();
- context = arbitrator?.Context ?? context;
- request = arbitrator?.UnaryRequest ?? request;
+ var hooks = InterceptCall(context, false, false, request)?.Freeze();
+ context = hooks?.ContextOverride ?? context;
+ request = hooks?.UnaryRequestOverride ?? request;
var response = continuation(request, context);
- if (arbitrator?.OnUnaryResponse != null)
+ if (hooks?.OnUnaryResponse != null)
{
- response = new AsyncUnaryCall<TResponse>(response.ResponseAsync.ContinueWith(unaryResponse => arbitrator.OnUnaryResponse(unaryResponse.Result)),
+ response = new AsyncUnaryCall<TResponse>(response.ResponseAsync.ContinueWith(unaryResponse => hooks.OnUnaryResponse(unaryResponse.Result)),
response.ResponseHeadersAsync, response.GetStatus, response.GetTrailers, response.Dispose);
}
return response;
@@ -189,14 +189,14 @@
/// </summary>
public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(TRequest request, ClientInterceptorContext<TRequest, TResponse> context, AsyncServerStreamingCallContinuation<TRequest, TResponse> continuation)
{
- var arbitrator = InterceptCall(context, false, true, request)?.Freeze();
- context = arbitrator?.Context ?? context;
- request = arbitrator?.UnaryRequest ?? request;
+ var hooks = InterceptCall(context, false, true, request)?.Freeze();
+ context = hooks?.ContextOverride ?? context;
+ request = hooks?.UnaryRequestOverride ?? request;
var response = continuation(request, context);
- if (arbitrator?.OnResponseMessage != null || arbitrator?.OnResponseStreamEnd != null)
+ if (hooks?.OnResponseMessage != null || hooks?.OnResponseStreamEnd != null)
{
response = new AsyncServerStreamingCall<TResponse>(
- new WrappedAsyncStreamReader<TResponse>(response.ResponseStream, arbitrator.OnResponseMessage, arbitrator.OnResponseStreamEnd),
+ new WrappedAsyncStreamReader<TResponse>(response.ResponseStream, hooks.OnResponseMessage, hooks.OnResponseStreamEnd),
response.ResponseHeadersAsync, response.GetStatus, response.GetTrailers, response.Dispose);
}
return response;
@@ -207,20 +207,20 @@
/// </summary>
public override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TResponse> context, AsyncClientStreamingCallContinuation<TRequest, TResponse> continuation)
{
- var arbitrator = InterceptCall(context, true, false, null)?.Freeze();
- context = arbitrator?.Context ?? context;
+ var hooks = InterceptCall(context, true, false, null)?.Freeze();
+ context = hooks?.ContextOverride ?? context;
var response = continuation(context);
- if (arbitrator?.OnRequestMessage != null || arbitrator?.OnResponseStreamEnd != null || arbitrator?.OnUnaryResponse != null)
+ if (hooks?.OnRequestMessage != null || hooks?.OnResponseStreamEnd != null || hooks?.OnUnaryResponse != null)
{
var requestStream = response.RequestStream;
- if (arbitrator?.OnRequestMessage != null || arbitrator?.OnRequestStreamEnd != null)
+ if (hooks?.OnRequestMessage != null || hooks?.OnRequestStreamEnd != null)
{
- requestStream = new WrappedClientStreamWriter<TRequest>(response.RequestStream, arbitrator.OnRequestMessage, arbitrator.OnRequestStreamEnd);
+ requestStream = new WrappedClientStreamWriter<TRequest>(response.RequestStream, hooks.OnRequestMessage, hooks.OnRequestStreamEnd);
}
var responseAsync = response.ResponseAsync;
- if (arbitrator?.OnUnaryResponse != null)
+ if (hooks?.OnUnaryResponse != null)
{
- responseAsync = response.ResponseAsync.ContinueWith(unaryResponse => arbitrator.OnUnaryResponse(unaryResponse.Result));
+ responseAsync = response.ResponseAsync.ContinueWith(unaryResponse => hooks.OnUnaryResponse(unaryResponse.Result));
}
response = new AsyncClientStreamingCall<TRequest, TResponse>(requestStream, responseAsync, response.ResponseHeadersAsync, response.GetStatus, response.GetTrailers, response.Dispose);
}
@@ -232,20 +232,20 @@
/// </summary>
public override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TResponse>(ClientInterceptorContext<TRequest, TResponse> context, AsyncDuplexStreamingCallContinuation<TRequest, TResponse> continuation)
{
- var arbitrator = InterceptCall(context, true, true, null)?.Freeze();
- context = arbitrator?.Context ?? context;
+ var hooks = InterceptCall(context, true, true, null)?.Freeze();
+ context = hooks?.ContextOverride ?? context;
var response = continuation(context);
- if (arbitrator?.OnRequestMessage != null || arbitrator?.OnRequestStreamEnd != null || arbitrator?.OnResponseMessage != null || arbitrator?.OnResponseStreamEnd != null)
+ if (hooks?.OnRequestMessage != null || hooks?.OnRequestStreamEnd != null || hooks?.OnResponseMessage != null || hooks?.OnResponseStreamEnd != null)
{
var requestStream = response.RequestStream;
- if (arbitrator?.OnRequestMessage != null || arbitrator?.OnRequestStreamEnd != null)
+ if (hooks?.OnRequestMessage != null || hooks?.OnRequestStreamEnd != null)
{
- requestStream = new WrappedClientStreamWriter<TRequest>(response.RequestStream, arbitrator.OnRequestMessage, arbitrator.OnRequestStreamEnd);
+ requestStream = new WrappedClientStreamWriter<TRequest>(response.RequestStream, hooks.OnRequestMessage, hooks.OnRequestStreamEnd);
}
var responseStream = response.ResponseStream;
- if (arbitrator?.OnResponseMessage != null || arbitrator?.OnResponseStreamEnd != null)
+ if (hooks?.OnResponseMessage != null || hooks?.OnResponseStreamEnd != null)
{
- responseStream = new WrappedAsyncStreamReader<TResponse>(response.ResponseStream, arbitrator.OnResponseMessage, arbitrator.OnResponseStreamEnd);
+ responseStream = new WrappedAsyncStreamReader<TResponse>(response.ResponseStream, hooks.OnResponseMessage, hooks.OnResponseStreamEnd);
}
response = new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream, response.ResponseHeadersAsync, response.GetStatus, response.GetTrailers, response.Dispose);
}
@@ -259,14 +259,14 @@
/// <typeparam name="TResponse">Response message type for this method.</typeparam>
public override async Task<TResponse> UnaryServerHandler<TRequest, TResponse>(TRequest request, ServerCallContext context, UnaryServerMethod<TRequest, TResponse> continuation)
{
- var arbitrator = (await InterceptHandler<TRequest, TResponse>(context, false, false, request))?.Freeze();
- request = arbitrator?.UnaryRequest ?? request;
+ var hooks = (await InterceptHandler<TRequest, TResponse>(context, false, false, request))?.Freeze();
+ request = hooks?.UnaryRequestOverride ?? request;
var response = await continuation(request, context);
- if (arbitrator?.OnUnaryResponse != null)
+ if (hooks?.OnUnaryResponse != null)
{
- response = arbitrator.OnUnaryResponse(response);
+ response = hooks.OnUnaryResponse(response);
}
- arbitrator?.OnHandlerEnd();
+ hooks?.OnHandlerEnd();
return response;
}
@@ -277,17 +277,17 @@
/// <typeparam name="TResponse">Response message type for this method.</typeparam>
public override async Task<TResponse> ClientStreamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, ServerCallContext context, ClientStreamingServerMethod<TRequest, TResponse> continuation)
{
- var arbitrator = (await InterceptHandler<TRequest, TResponse>(context, true, false, null))?.Freeze();
- if (arbitrator?.OnRequestMessage != null || arbitrator?.OnRequestStreamEnd != null)
+ var hooks = (await InterceptHandler<TRequest, TResponse>(context, true, false, null))?.Freeze();
+ if (hooks?.OnRequestMessage != null || hooks?.OnRequestStreamEnd != null)
{
- requestStream = new WrappedAsyncStreamReader<TRequest>(requestStream, arbitrator.OnRequestMessage, arbitrator.OnRequestStreamEnd);
+ requestStream = new WrappedAsyncStreamReader<TRequest>(requestStream, hooks.OnRequestMessage, hooks.OnRequestStreamEnd);
}
var response = await continuation(requestStream, context);
- if (arbitrator?.OnUnaryResponse != null)
+ if (hooks?.OnUnaryResponse != null)
{
- response = arbitrator.OnUnaryResponse(response);
+ response = hooks.OnUnaryResponse(response);
}
- arbitrator?.OnHandlerEnd();
+ hooks?.OnHandlerEnd();
return response;
}
@@ -298,14 +298,14 @@
/// <typeparam name="TResponse">Response message type for this method.</typeparam>
public override async Task ServerStreamingServerHandler<TRequest, TResponse>(TRequest request, IServerStreamWriter<TResponse> responseStream, ServerCallContext context, ServerStreamingServerMethod<TRequest, TResponse> continuation)
{
- var arbitrator = (await InterceptHandler<TRequest, TResponse>(context, false, true, request))?.Freeze();
- request = arbitrator?.UnaryRequest ?? request;
- if (arbitrator?.OnResponseMessage != null)
+ var hooks = (await InterceptHandler<TRequest, TResponse>(context, false, true, request))?.Freeze();
+ request = hooks?.UnaryRequestOverride ?? request;
+ if (hooks?.OnResponseMessage != null)
{
- responseStream = new WrappedAsyncStreamWriter<TResponse>(responseStream, arbitrator.OnResponseMessage);
+ responseStream = new WrappedAsyncStreamWriter<TResponse>(responseStream, hooks.OnResponseMessage);
}
await continuation(request, responseStream, context);
- arbitrator?.OnHandlerEnd();
+ hooks?.OnHandlerEnd();
}
/// <summary>
@@ -315,17 +315,17 @@
/// <typeparam name="TResponse">Response message type for this method.</typeparam>
public override async Task DuplexStreamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, IServerStreamWriter<TResponse> responseStream, ServerCallContext context, DuplexStreamingServerMethod<TRequest, TResponse> continuation)
{
- var arbitrator = (await InterceptHandler<TRequest, TResponse>(context, true, true, null))?.Freeze();
- if (arbitrator?.OnRequestMessage != null || arbitrator?.OnRequestStreamEnd != null)
+ var hooks = (await InterceptHandler<TRequest, TResponse>(context, true, true, null))?.Freeze();
+ if (hooks?.OnRequestMessage != null || hooks?.OnRequestStreamEnd != null)
{
- requestStream = new WrappedAsyncStreamReader<TRequest>(requestStream, arbitrator.OnRequestMessage, arbitrator.OnRequestStreamEnd);
+ requestStream = new WrappedAsyncStreamReader<TRequest>(requestStream, hooks.OnRequestMessage, hooks.OnRequestStreamEnd);
}
- if (arbitrator?.OnResponseMessage != null)
+ if (hooks?.OnResponseMessage != null)
{
- responseStream = new WrappedAsyncStreamWriter<TResponse>(responseStream, arbitrator.OnResponseMessage);
+ responseStream = new WrappedAsyncStreamWriter<TResponse>(responseStream, hooks.OnResponseMessage);
}
await continuation(requestStream, responseStream, context);
- arbitrator?.OnHandlerEnd();
+ hooks?.OnHandlerEnd();
}
private class WrappedAsyncStreamReader<T> : IAsyncStreamReader<T>