Searched defs:drainer (Results 1 – 3 of 3) sorted by relevance
235 std::unique_ptr<HttpResponseBodyDrainer> drainer) { in StartResponseDrainer()243 HttpResponseBodyDrainer* drainer) { in RemoveResponseDrainer()
202 private RetriableStream<String> newThrottledRetriableStream(Throttle throttle, Executor drainer) { in newThrottledRetriableStream()606 FakeClock drainer = new FakeClock(); in transparentRetry_cancel_race() local
863 async def drainer(stream): function