6 instantiations of StreamingInputCallRequest
InteropClient (6)
artifacts\obj\InteropClient\Release\net10.0\Messages.cs (2)
1567private static readonly pb::MessageParser<StreamingInputCallRequest> _parser = new pb::MessageParser<StreamingInputCallRequest>(() => new StreamingInputCallRequest()); 1604return new StreamingInputCallRequest(this);
InteropClient.cs (4)
311var bodySizes = new List<int> { 27182, 8, 1828, 45904 }.Select((size) => new StreamingInputCallRequest { Payload = CreateZerosPayload(size) }); 745await probeCall.RequestStream.WriteAsync(new StreamingInputCallRequest 764await call.RequestStream.WriteAsync(new StreamingInputCallRequest 774await call.RequestStream.WriteAsync(new StreamingInputCallRequest
17 references to StreamingInputCallRequest
InteropClient (17)
artifacts\obj\InteropClient\Release\net10.0\Messages.cs (11)
65new pbr::GeneratedClrTypeInfo(typeof(global::Grpc.Testing.StreamingInputCallRequest), global::Grpc.Testing.StreamingInputCallRequest.Parser, new[]{ "Payload", "ExpectCompressed" }, null, null, null, null), 1562public sealed partial class StreamingInputCallRequest : pb::IMessage<StreamingInputCallRequest> 1567private static readonly pb::MessageParser<StreamingInputCallRequest> _parser = new pb::MessageParser<StreamingInputCallRequest>(() => new StreamingInputCallRequest()); 1571public static pb::MessageParser<StreamingInputCallRequest> Parser { get { return _parser; } } 1595public StreamingInputCallRequest(StreamingInputCallRequest other) : this() { 1603public StreamingInputCallRequest Clone() { 1643return Equals(other as StreamingInputCallRequest); 1648public bool Equals(StreamingInputCallRequest other) { 1734public void MergeFrom(StreamingInputCallRequest other) {
artifacts\obj\InteropClient\Release\net10.0\TestGrpc.cs (6)
81static readonly grpc::Marshaller<global::Grpc.Testing.StreamingInputCallRequest> __Marshaller_grpc_testing_StreamingInputCallRequest = grpc::Marshallers.Create(__Helper_SerializeMessage, context => __Helper_DeserializeMessage(context, global::Grpc.Testing.StreamingInputCallRequest.Parser)); 118static readonly grpc::Method<global::Grpc.Testing.StreamingInputCallRequest, global::Grpc.Testing.StreamingInputCallResponse> __Method_StreamingInputCall = new grpc::Method<global::Grpc.Testing.StreamingInputCallRequest, global::Grpc.Testing.StreamingInputCallResponse>( 369public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.StreamingInputCallRequest, global::Grpc.Testing.StreamingInputCallResponse> StreamingInputCall(grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) 380public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.StreamingInputCallRequest, global::Grpc.Testing.StreamingInputCallResponse> StreamingInputCall(grpc::CallOptions options)