Lines Matching refs:new
45 server = new Server(new[] { new ChannelOption(ChannelOptions.SoReuseport, 0) })
47 Services = { TestService.BindService(new FakeTestService()) },
52 options = new List<ChannelOption>
54 new ChannelOption(ChannelOptions.SslTargetNameOverride, TestCredentials.DefaultHostOverride)
57 asyncAuthInterceptor = new AsyncAuthInterceptor(async (context, metadata) =>
76 channel = new Channel(Host, server.Ports.Single().BoundPort, channelCredentials, options);
77 client = new TestService.TestServiceClient(channel);
79 client.UnaryCall(new SimpleRequest { });
85 channel = new Channel(Host, server.Ports.Single().BoundPort, TestCredentials.CreateSslCredentials(), options);
86 client = new TestService.TestServiceClient(channel);
89 client.UnaryCall(new SimpleRequest { }, new CallOptions(credentials: callCredentials));
95 var first = CallCredentials.FromInterceptor(new AsyncAuthInterceptor((context, metadata) => {
100 var second = CallCredentials.FromInterceptor(new AsyncAuthInterceptor((context, metadata) => {
104 var third = CallCredentials.FromInterceptor(new AsyncAuthInterceptor((context, metadata) => {
110 channel = new Channel(Host, server.Ports.Single().BoundPort, channelCredentials, options);
111 var client = new TestService.TestServiceClient(channel);
112 var call = client.StreamingOutputCall(new StreamingOutputCallRequest { });
120 channel = new Channel(Host, server.Ports.Single().BoundPort, TestCredentials.CreateSslCredentials(), options);
121 var client = new TestService.TestServiceClient(channel);
122 var first = CallCredentials.FromInterceptor(new AsyncAuthInterceptor((context, metadata) => {
126 var second = CallCredentials.FromInterceptor(new AsyncAuthInterceptor((context, metadata) => {
130 var third = CallCredentials.FromInterceptor(new AsyncAuthInterceptor((context, metadata) => {
134 var call = client.StreamingOutputCall(new StreamingOutputCallRequest{ },
135 new CallOptions(credentials: CallCredentials.Compose(first, second, third)));
144 CallCredentials.FromInterceptor(new AsyncAuthInterceptor((context, metadata) => TaskUtils.CompletedTask)));
145 channel = new Channel(Host, server.Ports.Single().BoundPort, channelCredentials, options);
146 client = new TestService.TestServiceClient(channel);
148 var ex = Assert.Throws<RpcException>(() => client.UnaryCall(new SimpleRequest { }));
157 var callCredentials = CallCredentials.FromInterceptor(new AsyncAuthInterceptor((context, metadata) =>
159 throw new Exception(authInterceptorExceptionMessage);
162 channel = new Channel(Host, server.Ports.Single().BoundPort, channelCredentials, options);
163 client = new TestService.TestServiceClient(channel);
165 var ex = Assert.Throws<RpcException>(() => client.UnaryCall(new SimpleRequest { }));
176 return Task.FromResult(new SimpleResponse());
187 await responseStream.WriteAsync(new StreamingOutputCallResponse());
