Searched refs:WrittenMessagesReader (Results 1 – 2 of 2) sorted by relevance
100 var nextWriteTask = writer.WrittenMessagesReader.ReadAsync(); in Watch()103 nextWriteTask = writer.WrittenMessagesReader.ReadAsync(); in Watch()107 nextWriteTask = writer.WrittenMessagesReader.ReadAsync(); in Watch()111 nextWriteTask = writer.WrittenMessagesReader.ReadAsync(); in Watch()116 nextWriteTask = writer.WrittenMessagesReader.ReadAsync(); in Watch()141 var nextWriteTask1 = writer1.WrittenMessagesReader.ReadAsync(); in Watch_MultipleWatchesForSameService()142 var nextWriteTask2 = writer2.WrittenMessagesReader.ReadAsync(); in Watch_MultipleWatchesForSameService()146 nextWriteTask1 = writer1.WrittenMessagesReader.ReadAsync(); in Watch_MultipleWatchesForSameService()147 nextWriteTask2 = writer2.WrittenMessagesReader.ReadAsync(); in Watch_MultipleWatchesForSameService()152 nextWriteTask1 = writer1.WrittenMessagesReader.ReadAsync(); in Watch_MultipleWatchesForSameService()[all …]
44 public ChannelReader<HealthCheckResponse> WrittenMessagesReader => _channel.Reader; field in Grpc.HealthCheck.Tests.TestResponseStreamWriter