Lines Matching refs:stream

47     def __init__(self, stream):  argument
48         self.stream = stream
88                 output = await self.stream.recv(4096)
93                     await self.stream.send(data)
101                     await self.stream.send(data)
102                 output = await self.stream.recv(4096)
119         await self.stream.send(encode)
123         data = await self.stream.recv(buffersize)
126             data = await self.stream.recv(buffersize)
138                 more = await self.stream.recv(buffersize)
141                     more = await self.stream.recv(buffersize)