Searched refs:moveNextTask (Results 1 – 3 of 3) sorted by relevance
77 var moveNextTask = requestStream.MoveNext(); in CancelNotificationAfterStartDisposesAfterPendingReadFinishes()81 Assert.IsFalse(moveNextTask.Result); in CancelNotificationAfterStartDisposesAfterPendingReadFinishes()95 var moveNextTask = requestStream.MoveNext(); in ReadAfterCancelNotificationCanSucceed()96 Assert.IsFalse(moveNextTask.Result); in ReadAfterCancelNotificationCanSucceed()109 var moveNextTask = requestStream.MoveNext(); in ReadCompletionFailureClosesRequestStream()111 Assert.IsFalse(moveNextTask.Result); in ReadCompletionFailureClosesRequestStream()
657 …ponseSuccess(AsyncCall<string, string> asyncCall, FakeNativeCall fakeCall, Task<bool> moveNextTask) in AssertStreamingResponseSuccess() argument659 Assert.IsTrue(moveNextTask.IsCompleted); in AssertStreamingResponseSuccess()662 Assert.IsFalse(moveNextTask.Result); in AssertStreamingResponseSuccess()679 …ncCall<string, string> asyncCall, FakeNativeCall fakeCall, Task<bool> moveNextTask, StatusCode exp… in AssertStreamingResponseError() argument681 Assert.IsTrue(moveNextTask.IsCompleted); in AssertStreamingResponseError()684 var ex = Assert.ThrowsAsync<RpcException>(async () => await moveNextTask); in AssertStreamingResponseError()
131 var moveNextTask = requestStream.MoveNext(cts.Token); in ClientStreamingCall_CancelServerSideRead()133 await moveNextTask; in ClientStreamingCall_CancelServerSideRead()167 var moveNextTask = call.ResponseStream.MoveNext(cts.Token); in ServerStreamingCall_CancelClientSideRead()173 await moveNextTask; in ServerStreamingCall_CancelClientSideRead()