Lines Matching full:self
149 def __init__(self, request, onmessage=None):
160 threading.Thread.__init__(self)
161 self._request = request
162 self._queue = Queue.Queue()
163 self._onmessage = onmessage
164 self._stop_requested = False
165 self.setDaemon(True)
166 self.start()
168 def run(self):
169 while not self._stop_requested:
170 message = receive_message(self._request)
171 if self._onmessage:
172 self._onmessage(message)
174 self._queue.put(message)
176 def receive(self):
182 return self._queue.get()
184 def receive_nowait(self):
191 message = self._queue.get_nowait()
196 def stop(self):
203 self._stop_requested = True
216 def __init__(self, request):
222 threading.Thread.__init__(self)
223 self._request = request
224 self._queue = Queue.Queue()
225 self.setDaemon(True)
226 self.start()
228 def run(self):
230 message, condition = self._queue.get()
232 send_message(self._request, message)
236 def send(self, message):
241 self._queue.put((message, condition))
244 def send_nowait(self, message):
247 self._queue.put((message, threading.Condition()))
