Merge pull request #43667 from CyrusNajmabadi/streamOverload

Add overload for rpc that can work on streams, not just object writers.
dotnet · Apr 25, 2020 · 3ad5952 · 3ad5952
2 parents 7e1880d + e97c02d
commit 3ad5952
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/Workspaces/Remote/ServiceHub/Shared/RemoteEndPoint.cs b/src/Workspaces/Remote/ServiceHub/Shared/RemoteEndPoint.cs
@@ -192,10 +192,10 @@ public async Task<T> InvokeAsync<T>(string targetName, IReadOnlyList<object?> ar
 
         public static Task WriteDataToNamedPipeAsync<TData>(string pipeName, TData data, Func<ObjectWriter, TData, CancellationToken, Task> dataWriter, CancellationToken cancellationToken)
             => WriteDataToNamedPipeAsync(pipeName, data,
-                async (s, d, c) =>
+                async (stream, data, cancellationToken) =>
                 {
-                    using var objectWriter = new ObjectWriter(s, leaveOpen: true, c);
-                    await dataWriter(objectWriter, d, c).ConfigureAwait(false);
+                    using var objectWriter = new ObjectWriter(stream, leaveOpen: true, cancellationToken);
+                    await dataWriter(objectWriter, data, cancellationToken).ConfigureAwait(false);
                 }, cancellationToken);
 
         public static async Task WriteDataToNamedPipeAsync<TData>(string pipeName, TData data, Func<Stream, TData, CancellationToken, Task> dataWriter, CancellationToken cancellationToken)