| /third_party/grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | AsyncCallTest.cs | 392 var readTask = responseStream.MoveNext(); in ServerStreaming_NoResponse_Success1()
408 var readTask = responseStream.MoveNext(); in ServerStreaming_NoResponse_Success2()
422 var readTask = responseStream.MoveNext(); in ServerStreaming_NoResponse_ReadFailure()
436 var readTask1 = responseStream.MoveNext(); in ServerStreaming_MoreResponses_Success()
441 var readTask2 = responseStream.MoveNext(); in ServerStreaming_MoreResponses_Success()
446 var readTask3 = responseStream.MoveNext(); in ServerStreaming_MoreResponses_Success()
462 var readTask = responseStream.MoveNext(); in ServerStreaming_RequestSerializationExceptionDoesntLeakResources()
485 var readTask = responseStream.MoveNext(); in DuplexStreaming_NoRequestNoResponse_Success()
499 var readTask = responseStream.MoveNext(); in DuplexStreaming_WriteAfterReceivingStatusThrowsRpcException()
517 var readTask = responseStream.MoveNext(); in DuplexStreaming_CompleteAfterReceivingStatusSuceeds()
[all …]
|
| D | DefaultDeserializationContextTest.cs | 105 Assert.IsTrue(segmentEnumerator.MoveNext()); in PayloadAsReadOnlySequence_MultiSegmentPayload()
108 Assert.IsTrue(segmentEnumerator.MoveNext()); in PayloadAsReadOnlySequence_MultiSegmentPayload()
111 Assert.IsTrue(segmentEnumerator.MoveNext()); in PayloadAsReadOnlySequence_MultiSegmentPayload()
114 Assert.IsFalse(segmentEnumerator.MoveNext()); in PayloadAsReadOnlySequence_MultiSegmentPayload()
|
| D | AsyncCallServerTest.cs | 80 var moveNextTask = requestStream.MoveNext(); in CancelNotificationAfterStartDisposesAfterPendingReadFinishes()
98 var moveNextTask = requestStream.MoveNext(); in ReadAfterCancelNotificationCanSucceed()
112 var moveNextTask = requestStream.MoveNext(); in ReadCompletionFailureClosesRequestStream()
|
| D | FakeBufferReaderManager.cs | 89 if (!segmentEnumerator.MoveNext()) in TryGetNextSlice()
|
| /third_party/grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | WorkerServiceImpl.cs | 44 GrpcPreconditions.CheckState(await requestStream.MoveNext()); in RunServer()
55 while (await requestStream.MoveNext()) in RunServer()
68 GrpcPreconditions.CheckState(await requestStream.MoveNext()); in RunClient()
77 while (await requestStream.MoveNext()) in RunClient()
|
| D | InteropClient.cs | 274 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
283 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
292 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
301 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
306 Assert.IsFalse(await call.ResponseStream.MoveNext()); in RunPingPongAsync()
433 Assert.IsTrue(await call.ResponseStream.MoveNext()); in RunCancelAfterFirstResponseAsync()
441 await call.ResponseStream.MoveNext(); in RunCancelAfterFirstResponseAsync()
474 await call.ResponseStream.MoveNext(); in RunTimeoutOnSleepingServerAsync()
|
| D | GeneratedServiceBaseTest.cs | 81 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in UnimplementedByDefault_ServerStreamingCall()
90 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in UnimplementedByDefault_DuplexStreamingCall()
|
| D | ClientRunners.cs | 264 await call.ResponseStream.MoveNext(); in RunStreamingPingPongAsync()
275 Assert.IsFalse(await call.ResponseStream.MoveNext()); in RunStreamingPingPongAsync()
292 await call.ResponseStream.MoveNext(); in RunGenericStreamingAsync()
303 Assert.IsFalse(await call.ResponseStream.MoveNext()); in RunGenericStreamingAsync()
|
| D | MetadataCredentialsTest.cs | 179 Assert.IsTrue(await call.ResponseStream.MoveNext()); in MetadataCredentials_Composed()
180 Assert.IsFalse(await call.ResponseStream.MoveNext()); in MetadataCredentials_Composed()
207 Assert.IsTrue(await call.ResponseStream.MoveNext()); in MetadataCredentials_ComposedPerCall()
208 Assert.IsFalse(await call.ResponseStream.MoveNext()); in MetadataCredentials_ComposedPerCall()
|
| D | UnobservedTaskExceptionTest.cs | 91 var firstResponse = await call.ResponseStream.MoveNext(); in NoUnobservedTaskExceptionForAbandonedStreamingResponse()
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/ |
| D | CallCancellationTest.cs | 102 var moveNextResult = await requestStream.MoveNext(); in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
131 var moveNextTask = requestStream.MoveNext(cts.Token); in ClientStreamingCall_CancelServerSideRead()
163 await call.ResponseStream.MoveNext(); in ServerStreamingCall_CancelClientSideRead()
167 var moveNextTask = call.ResponseStream.MoveNext(cts.Token); in ServerStreamingCall_CancelClientSideRead()
|
| D | ClientServerTest.cs | 231 Assert.IsFalse(await call.ResponseStream.MoveNext()); in ServerStreamingCall_EndOfStreamIsIdempotent()
232 Assert.IsFalse(await call.ResponseStream.MoveNext()); in ServerStreamingCall_EndOfStreamIsIdempotent()
246 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ServerStreamingCall_ErrorCanBeAwaitedTwice()
250 … var ex2 = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ServerStreamingCall_ErrorCanBeAwaitedTwice()
265 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ServerStreamingCall_TrailersFromMultipleSourcesGetConcatenated()
280 while (await requestStream.MoveNext()) in DuplexStreamingCall()
|
| D | MarshallingErrorsTest.cs | 100 … var ex = Assert.ThrowsAsync<RpcException>(async () => await call.ResponseStream.MoveNext()); in ResponseParsingError_StreamingResponse()
125 await requestStream.MoveNext(); in RequestParsingError_StreamingRequest()
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/ |
| D | AsyncStreamReaderExtensions.cs | 39 public static Task<bool> MoveNext<T>(this IAsyncStreamReader<T> streamReader)
47 return streamReader.MoveNext(CancellationToken.None);
|
| D | IAsyncStreamReader.cs | 64 Task<bool> MoveNext(CancellationToken cancellationToken); in MoveNext() method
|
| /third_party/grpc/src/csharp/Grpc.Core/Utils/ |
| D | AsyncStreamExtensions.cs | 36 while (await streamReader.MoveNext().ConfigureAwait(false))
49 while (await streamReader.MoveNext().ConfigureAwait(false))
|
| /third_party/grpc/examples/csharp/RouteGuide/RouteGuideServer/ |
| D | RouteGuideImpl.cs | 76 while (await requestStream.MoveNext()) in RecordRoute()
108 while (await requestStream.MoveNext()) in RouteChat()
|
| /third_party/grpc/src/csharp/Grpc.Reflection.Tests/ |
| D | ReflectionClientServerTest.cs | 132 Assert.IsTrue(await call.ResponseStream.MoveNext()); in SingleRequestAsync()
136 Assert.IsFalse(await call.ResponseStream.MoveNext()); in SingleRequestAsync()
|
| /third_party/glib/gio/ |
| D | gwin32api-iterator.h | 43 HRESULT (STDMETHODCALLTYPE *MoveNext)(
71 #define IIterator_MoveNext(This,hasCurrent) (This)->lpVtbl->MoveNext(This,hasCurrent)
|
| /third_party/protobuf/csharp/src/Google.Protobuf/ |
| D | SegmentedBufferHelper.cs | 86 instance.readOnlySequenceEnumerator.MoveNext(); in Initialize()
187 while (readOnlySequenceEnumerator.MoveNext()) in RefillFromReadOnlySequence()
|
| /third_party/grpc/examples/csharp/RouteGuide/RouteGuideClient/ |
| D | Program.cs | 90 while (await responseStream.MoveNext()) in ListFeatures()
168 while (await call.ResponseStream.MoveNext()) in RouteChat()
|
| /third_party/grpc/src/csharp/Grpc.Core/Internal/ |
| D | ServerRequestStream.cs | 50 public async Task<bool> MoveNext(CancellationToken token) in MoveNext() method in Grpc.Core.Internal.ServerRequestStream
|
| D | ClientResponseStream.cs | 50 public async Task<bool> MoveNext(CancellationToken token) in MoveNext() method in Grpc.Core.Internal.ClientResponseStream
|
| /third_party/protobuf/csharp/compatibility_tests/v3.0.0/src/Google.Protobuf.Test/Collections/ |
| D | MapFieldTest.cs | 298 Assert.IsTrue(enumerator.MoveNext()); in IDictionary_GetEnumerator()
303 Assert.IsFalse(enumerator.MoveNext()); in IDictionary_GetEnumerator()
307 Assert.IsTrue(enumerator.MoveNext()); in IDictionary_GetEnumerator()
|
| D | RepeatedFieldTest.cs | 297 Assert.IsTrue(enumerator.MoveNext()); in Enumerator()
299 Assert.IsTrue(enumerator.MoveNext()); in Enumerator()
301 Assert.IsFalse(enumerator.MoveNext()); in Enumerator()
302 Assert.IsFalse(enumerator.MoveNext()); in Enumerator()
|