Lines Matching refs:expecter

7 def expect_async(expecter, timeout=None):  argument
10     previously_read = expecter.spawn.buffer
11     expecter.spawn._buffer = expecter.spawn.buffer_type()
12     expecter.spawn._before = expecter.spawn.buffer_type()
13     idx = expecter.new_data(previously_read)
16     if not expecter.spawn.async_pw_transport:
18         pw.set_expecter(expecter)
20             .connect_read_pipe(lambda: pw, expecter.spawn)
21         expecter.spawn.async_pw_transport = pw, transport
23         pw, transport = expecter.spawn.async_pw_transport
24         pw.set_expecter(expecter)
30         return expecter.timeout(e)
36     def set_expecter(self, expecter):  argument
37         self.expecter = expecter
54         spawn = self.expecter.spawn
63             index = self.expecter.new_data(s)
68             self.expecter.errored()
75             self.expecter.spawn.flag_eof = True
76             index = self.expecter.eof()