original_docstring: Send an event to the running process.
docstring: Send an event to the running process.
docstring_tokens: Send an event to the running process .
code: async def send_event(self, evt):
          """Send an event to the running process."""
          if self._q is None:
              if self._running:
                  self._logger.info("Discarding %r", evt)
          elif self._q.qsize() < QLEN - 1:
              self._logger.debug("Event: %r", evt)
              await self._q.put(evt)
          elif self._q.qsize() == QLEN - 1:
              self._logger.warning("Queue full")
              await self._q.put(None)
              self._q = None
              self._logger.info("Discarding %r", evt)
code_tokens: async def send_event ( self , evt ) : if self . _q is None : if self . _running : self . _logger . info ( "Discarding %r" , evt ) elif self . _q . qsize ( ) < QLEN - 1 : self . _logger . debug ( "Event: %r" , evt ) await self . _q . put ( evt ) elif self . _q . qsize ( ) == QLEN - 1 : self . _logger . warning ( "Queue full" ) await self . _q . put ( None ) self . _q = None self . _logger . info ( "Discarding %r" , evt )
short_docstring: Send an event to the running process.
short_docstring_tokens: Send an event to the running process .
comment: """Send an event to the running process."""