Searched refs:read_task (Results 1 – 6 of 6) sorted by relevance
55 std::function<void()> read_task; member60 bool Enable(std::function<void()> read_task, in Enable() argument63 PERFETTO_DCHECK(read_task); in Enable()70 dg->read_task = std::move(read_task); in Enable()83 dg->read_task = nullptr; in Disable()117 auto read_task = Delegate::GetInstance()->read_task; in AppendNewRecord() local118 if (read_task) in AppendNewRecord()119 read_task(); in AppendNewRecord()
172 auto read_task = [&last_value_read] { in TEST_F() local191 EXPECT_CALL(*this, ReadCallback()).WillRepeatedly(Invoke(read_task)); in TEST_F()215 read_task(); // Do a final read pass. in TEST_F()
164 read_task = self.loop.create_task(stream.read(30))170 data = self.loop.run_until_complete(read_task)188 read_task = self.loop.create_task(stream.read(1024))194 data = self.loop.run_until_complete(read_task)201 read_task = self.loop.create_task(stream.read(-1))209 data = self.loop.run_until_complete(read_task)244 read_task = self.loop.create_task(stream.readline())252 line = self.loop.run_until_complete(read_task)500 read_task = self.loop.create_task(stream.readexactly(n))508 data = self.loop.run_until_complete(read_task)[all …]
77 bool Enable(std::function<void()> read_task, base::TaskRunner*, uint32_t tags);
363 let read_task = read_events(event, signal_wait, &ex); in event() localVariable364 ex.run_until(futures::future::join(read_task, write_task)) in event()
965 let read_task = rx_source in canceled_before_completion() localVariable969 ex.spawn_local(cancel_io(read_task)).detach(); in canceled_before_completion()