Home
last modified time | relevance | path

Searched refs:ReceivedMessageCallback (Results 1 – 4 of 4) sorted by relevance

/external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/
DAsyncCallTest.cs393 fakeCall.ReceivedMessageCallback.OnReceivedMessage(true, null); in ServerStreaming_NoResponse_Success1()
408 fakeCall.ReceivedMessageCallback.OnReceivedMessage(true, null); in ServerStreaming_NoResponse_Success2()
420 …fakeCall.ReceivedMessageCallback.OnReceivedMessage(false, null); // after a failed read, we rely … in ServerStreaming_NoResponse_ReadFailure()
433 fakeCall.ReceivedMessageCallback.OnReceivedMessage(true, CreateResponsePayload()); in ServerStreaming_MoreResponses_Success()
438 fakeCall.ReceivedMessageCallback.OnReceivedMessage(true, CreateResponsePayload()); in ServerStreaming_MoreResponses_Success()
444 fakeCall.ReceivedMessageCallback.OnReceivedMessage(true, null); in ServerStreaming_MoreResponses_Success()
482 fakeCall.ReceivedMessageCallback.OnReceivedMessage(true, null); in DuplexStreaming_NoRequestNoResponse_Success()
496 fakeCall.ReceivedMessageCallback.OnReceivedMessage(true, null); in DuplexStreaming_WriteAfterReceivingStatusThrowsRpcException()
514 fakeCall.ReceivedMessageCallback.OnReceivedMessage(true, null); in DuplexStreaming_CompleteAfterReceivingStatusSuceeds()
536 fakeCall.ReceivedMessageCallback.OnReceivedMessage(true, null); in DuplexStreaming_WriteFailureThrowsRpcException()
[all …]
DFakeNativeCall.cs47 public IReceivedMessageCallback ReceivedMessageCallback property in Grpc.Core.Internal.Tests.FakeNativeCall
136 ReceivedMessageCallback = callback; in StartReceiveMessage()
DAsyncCallServerTest.cs80 fakeCall.ReceivedMessageCallback.OnReceivedMessage(true, null); in CancelNotificationAfterStartDisposesAfterPendingReadFinishes()
110 fakeCall.ReceivedMessageCallback.OnReceivedMessage(false, null); in ReadCompletionFailureClosesRequestStream()
/external/grpc-grpc/src/csharp/Grpc.Core/Internal/
DAsyncCallBase.cs157 call.StartReceiveMessage(ReceivedMessageCallback); in ReadMessageInternalAsync()
375 IReceivedMessageCallback ReceivedMessageCallback => this; field in Grpc.Core.Internal.AsyncCallBase