Skip to content
Snippets Groups Projects
Commit 392d1e0c authored by Jan Tattermusch's avatar Jan Tattermusch
Browse files

addressed review comments

parent 6b7523d5
No related branches found
No related tags found
No related merge requests found
...@@ -5,6 +5,11 @@ using System.Collections.Concurrent; ...@@ -5,6 +5,11 @@ using System.Collections.Concurrent;
namespace Google.GRPC.Core.Utils namespace Google.GRPC.Core.Utils
{ {
/// <summary>
/// Observer that allows us to await incoming messages one-by-one.
/// The implementation is not ideal and class will be probably replaced
/// by something more versatile in the future.
/// </summary>
public class RecordingQueue<T> : IObserver<T> public class RecordingQueue<T> : IObserver<T>
{ {
readonly BlockingCollection<T> queue = new BlockingCollection<T>(); readonly BlockingCollection<T> queue = new BlockingCollection<T>();
......
...@@ -7,9 +7,9 @@ using Google.GRPC.Core.Utils; ...@@ -7,9 +7,9 @@ using Google.GRPC.Core.Utils;
using Google.ProtocolBuffers; using Google.ProtocolBuffers;
using grpc.testing; using grpc.testing;
namespace InteropClient namespace Google.GRPC.Interop
{ {
class InteropClient class Client
{ {
private class ClientOptions private class ClientOptions
{ {
...@@ -24,7 +24,8 @@ namespace InteropClient ...@@ -24,7 +24,8 @@ namespace InteropClient
ClientOptions options; ClientOptions options;
private InteropClient(ClientOptions options) { private Client(ClientOptions options)
{
this.options = options; this.options = options;
} }
...@@ -53,7 +54,7 @@ namespace InteropClient ...@@ -53,7 +54,7 @@ namespace InteropClient
Environment.Exit(1); Environment.Exit(1);
} }
var interopClient = new InteropClient(options); var interopClient = new Client(options);
interopClient.Run(); interopClient.Run();
} }
......
...@@ -9,7 +9,7 @@ ...@@ -9,7 +9,7 @@
<OutputType>Exe</OutputType> <OutputType>Exe</OutputType>
<RootNamespace>InteropClient</RootNamespace> <RootNamespace>InteropClient</RootNamespace>
<AssemblyName>InteropClient</AssemblyName> <AssemblyName>InteropClient</AssemblyName>
<StartupObject>InteropClient.InteropClient</StartupObject> <StartupObject>Google.GRPC.Interop.Client</StartupObject>
<TargetFrameworkVersion>v4.5</TargetFrameworkVersion> <TargetFrameworkVersion>v4.5</TargetFrameworkVersion>
</PropertyGroup> </PropertyGroup>
<PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|x86' "> <PropertyGroup Condition=" '$(Configuration)|$(Platform)' == 'Debug|x86' ">
...@@ -43,7 +43,7 @@ ...@@ -43,7 +43,7 @@
</ItemGroup> </ItemGroup>
<ItemGroup> <ItemGroup>
<Compile Include="Properties\AssemblyInfo.cs" /> <Compile Include="Properties\AssemblyInfo.cs" />
<Compile Include="InteropClient.cs" /> <Compile Include="Client.cs" />
</ItemGroup> </ItemGroup>
<Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" /> <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
<ItemGroup> <ItemGroup>
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment