/dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/arrow/csharp/src/Apache.Arrow.Flight/Client/ |
H A D | FlightClient.cs | 47 … new AsyncServerStreamingCall<FlightInfo>(convertStream, response.ResponseHeadersAsync, response.G… in ListFlights() 55 …syncServerStreamingCall<FlightActionType>(convertStream, response.ResponseHeadersAsync, response.G… in ListActions() 62 …return new FlightRecordBatchStreamingCall(responseStream, stream.ResponseHeadersAsync, stream.GetS… in GetStream() 76 flightInfoResult.ResponseHeadersAsync, in GetInfo() 90 channels.ResponseHeadersAsync, in StartPut() 100 …n new AsyncServerStreamingCall<FlightResult>(streamReader, stream.ResponseHeadersAsync, stream.Get… in DoAction() 114 schemaResult.ResponseHeadersAsync, in GetSchema()
|
H A D | FlightRecordBatchStreamingCall.cs | 36 ResponseHeadersAsync = responseHeadersAsync; in FlightRecordBatchStreamingCall() 47 public Task<Metadata> ResponseHeadersAsync { get; } property in Apache.Arrow.Flight.Client.FlightRecordBatchStreamingCall
|
H A D | FlightRecordBatchDuplexStreamingCall.cs | 38 ResponseHeadersAsync = responseHeadersAsync; in FlightRecordBatchDuplexStreamingCall() 57 public Task<Metadata> ResponseHeadersAsync { get; } property in Apache.Arrow.Flight.Client.FlightRecordBatchDuplexStreamingCall
|
/dports/databases/arrow/apache-arrow-6.0.1/csharp/src/Apache.Arrow.Flight/Client/ |
H A D | FlightClient.cs | 47 … new AsyncServerStreamingCall<FlightInfo>(convertStream, response.ResponseHeadersAsync, response.G… in ListFlights() 55 …syncServerStreamingCall<FlightActionType>(convertStream, response.ResponseHeadersAsync, response.G… in ListActions() 62 …return new FlightRecordBatchStreamingCall(responseStream, stream.ResponseHeadersAsync, stream.GetS… in GetStream() 76 flightInfoResult.ResponseHeadersAsync, in GetInfo() 90 channels.ResponseHeadersAsync, in StartPut() 100 …n new AsyncServerStreamingCall<FlightResult>(streamReader, stream.ResponseHeadersAsync, stream.Get… in DoAction() 114 schemaResult.ResponseHeadersAsync, in GetSchema()
|
H A D | FlightRecordBatchStreamingCall.cs | 36 ResponseHeadersAsync = responseHeadersAsync; in FlightRecordBatchStreamingCall() 47 public Task<Metadata> ResponseHeadersAsync { get; } property in Apache.Arrow.Flight.Client.FlightRecordBatchStreamingCall
|
H A D | FlightRecordBatchDuplexStreamingCall.cs | 38 ResponseHeadersAsync = responseHeadersAsync; in FlightRecordBatchDuplexStreamingCall() 57 public Task<Metadata> ResponseHeadersAsync { get; } property in Apache.Arrow.Flight.Client.FlightRecordBatchDuplexStreamingCall
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/csharp/Grpc.Core/ |
H A D | Calls.cs | 62 …return new AsyncUnaryCall<TResponse>(asyncResult, asyncCall.ResponseHeadersAsync, asyncCall.GetSta… 81 …new AsyncServerStreamingCall<TResponse>(responseStream, asyncCall.ResponseHeadersAsync, asyncCall.… 99 …ingCall<TRequest, TResponse>(requestStream, resultTask, asyncCall.ResponseHeadersAsync, asyncCall.… 119 …all<TRequest, TResponse>(requestStream, responseStream, asyncCall.ResponseHeadersAsync, asyncCall.…
|
/dports/devel/grpc/grpc-1.42.0/src/csharp/Grpc.Core.Tests/Internal/ |
H A D | AsyncCallTest.cs | 395 Assert.AreEqual(0, asyncCall.ResponseHeadersAsync.Result.Count); in ServerStreaming_NoResponse_Success1() 441 Assert.AreEqual(0, asyncCall.ResponseHeadersAsync.Result.Count); in ServerStreaming_NoResponse_ReadFailure() 456 Assert.AreEqual(0, asyncCall.ResponseHeadersAsync.Result.Count); in ServerStreaming_MoreResponses_Success() 504 Assert.AreEqual(0, asyncCall.ResponseHeadersAsync.Result.Count); in DuplexStreaming_NoRequestNoResponse_Success1() 533 Assert.AreEqual(0, asyncCall.ResponseHeadersAsync.Result.Count); in DuplexStreaming_NoRequestNoResponse_Success2() 546 Assert.AreEqual(0, asyncCall.ResponseHeadersAsync.Result.Count); in DuplexStreaming_WriteAfterReceivingStatusThrowsRpcException() 567 Assert.AreEqual(0, asyncCall.ResponseHeadersAsync.Result.Count); in DuplexStreaming_CompleteAfterReceivingStatusSuceeds() 586 Assert.AreEqual(0, asyncCall.ResponseHeadersAsync.Result.Count); in DuplexStreaming_WriteFailureThrowsRpcException() 612 Assert.AreEqual(0, asyncCall.ResponseHeadersAsync.Result.Count); in DuplexStreaming_WriteFailureThrowsRpcException2() 635 Assert.AreEqual(0, asyncCall.ResponseHeadersAsync.Result.Count); in DuplexStreaming_WriteAfterCancellationRequestThrowsTaskCanceledException() [all …]
|
H A D | AsyncCallStateTest.cs | 35 Assert.AreSame(responseHeaders, state.ResponseHeadersAsync()); in Stateless() 69 Assert.AreSame(callbackState.responseHeaders, state.ResponseHeadersAsync()); in WithState()
|
/dports/devel/grpc/grpc-1.42.0/src/csharp/Grpc.Core.Tests/ |
H A D | ResponseHeadersTest.cs | 74 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_UnaryCall() 94 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_ClientStreamingCall() 110 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_ServerStreamingCall() 129 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_DuplexStreamingCall()
|
/dports/devel/grpc130/grpc-1.30.2/src/csharp/Grpc.Core.Tests/ |
H A D | ResponseHeadersTest.cs | 74 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_UnaryCall() 94 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_ClientStreamingCall() 110 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_ServerStreamingCall() 129 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_DuplexStreamingCall()
|
/dports/devel/grpc134/grpc-1.34.1/src/csharp/Grpc.Core.Tests/ |
H A D | ResponseHeadersTest.cs | 74 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_UnaryCall() 94 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_ClientStreamingCall() 110 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_ServerStreamingCall() 129 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_DuplexStreamingCall()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/csharp/Grpc.Core.Tests/ |
H A D | ResponseHeadersTest.cs | 74 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_UnaryCall() 94 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_ClientStreamingCall() 110 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_ServerStreamingCall() 129 var responseHeaders = await call.ResponseHeadersAsync; in ResponseHeadersAsync_DuplexStreamingCall()
|
/dports/devel/grpc134/grpc-1.34.1/src/csharp/Grpc.Core.Api/ |
H A D | AsyncServerStreamingCall.cs | 85 public Task<Metadata> ResponseHeadersAsync property in Grpc.Core.AsyncServerStreamingCall 89 return callState.ResponseHeadersAsync();
|
H A D | AsyncUnaryCall.cs | 87 public Task<Metadata> ResponseHeadersAsync property in Grpc.Core.AsyncUnaryCall 91 return callState.ResponseHeadersAsync();
|
H A D | AsyncDuplexStreamingCall.cs | 104 public Task<Metadata> ResponseHeadersAsync property in Grpc.Core.AsyncDuplexStreamingCall 108 return callState.ResponseHeadersAsync();
|
H A D | AsyncClientStreamingCall.cs | 94 public Task<Metadata> ResponseHeadersAsync property in Grpc.Core.AsyncClientStreamingCall 98 return callState.ResponseHeadersAsync();
|
/dports/devel/grpc130/grpc-1.30.2/src/csharp/Grpc.Core.Api/ |
H A D | AsyncServerStreamingCall.cs | 85 public Task<Metadata> ResponseHeadersAsync property in Grpc.Core.AsyncServerStreamingCall 89 return callState.ResponseHeadersAsync();
|
H A D | AsyncUnaryCall.cs | 87 public Task<Metadata> ResponseHeadersAsync property in Grpc.Core.AsyncUnaryCall 91 return callState.ResponseHeadersAsync();
|
H A D | AsyncDuplexStreamingCall.cs | 104 public Task<Metadata> ResponseHeadersAsync property in Grpc.Core.AsyncDuplexStreamingCall 108 return callState.ResponseHeadersAsync();
|
H A D | AsyncClientStreamingCall.cs | 94 public Task<Metadata> ResponseHeadersAsync property in Grpc.Core.AsyncClientStreamingCall 98 return callState.ResponseHeadersAsync();
|
/dports/devel/grpc/grpc-1.42.0/src/csharp/Grpc.Core.Api/ |
H A D | AsyncServerStreamingCall.cs | 85 public Task<Metadata> ResponseHeadersAsync property in Grpc.Core.AsyncServerStreamingCall 89 return callState.ResponseHeadersAsync();
|
H A D | AsyncUnaryCall.cs | 87 public Task<Metadata> ResponseHeadersAsync property in Grpc.Core.AsyncUnaryCall 91 return callState.ResponseHeadersAsync();
|
H A D | AsyncDuplexStreamingCall.cs | 104 public Task<Metadata> ResponseHeadersAsync property in Grpc.Core.AsyncDuplexStreamingCall 108 return callState.ResponseHeadersAsync();
|
H A D | AsyncClientStreamingCall.cs | 94 public Task<Metadata> ResponseHeadersAsync property in Grpc.Core.AsyncClientStreamingCall 98 return callState.ResponseHeadersAsync();
|