diff --git a/src/DynamicGrpc/DynamicGrpcClient.cs b/src/DynamicGrpc/DynamicGrpcClient.cs index a4ed3b7..24369f4 100644 --- a/src/DynamicGrpc/DynamicGrpcClient.cs +++ b/src/DynamicGrpc/DynamicGrpcClient.cs @@ -102,7 +102,7 @@ public static async Task FromServerReflection(ChannelBase cha if (methodDescriptor.IsServerStreaming) { // Full streaming duplex - var call = AsyncDuplexStreamingCall(serviceName, methodName); + var call = AsyncDuplexStreamingCall(serviceName, methodName, host, options); await foreach (var item in input) { await call.RequestStream.WriteAsync(item); @@ -118,7 +118,7 @@ await foreach (var item in input) else { // Client streaming only - var call = AsyncClientStreamingCall(serviceName, methodName); + var call = AsyncClientStreamingCall(serviceName, methodName, host, options); await foreach (var item in input) { await call.RequestStream.WriteAsync(item); @@ -139,7 +139,7 @@ await foreach (var item in input) break; // Take only the first element } - var call = AsyncServerStreamingCall(serviceName, methodName, firstInput ?? new Dictionary()); + var call = AsyncServerStreamingCall(serviceName, methodName, firstInput ?? new Dictionary(), host, options); var responseStream = call.ResponseStream; while (await responseStream.MoveNext()) { @@ -156,7 +156,7 @@ await foreach (var item in input) break; // Take only the first element } - var result = await AsyncUnaryCall(serviceName, methodName, firstInput ?? new Dictionary()); + var result = await AsyncUnaryCall(serviceName, methodName, firstInput ?? new Dictionary(), host, options); yield return result; } }