parameters: (self)
docstring: Run the pipe dispatcher.
docstring_summary: Run the pipe dispatcher.
docstring_tokens: Run the pipe dispatcher .
function: def run(self):
          """Run the pipe dispatcher."""
          buf = create_string_buffer(BUFSIZE)
          bytes_written = c_uint()
  
          while self.do_run:
              message = self._read_message(buf)
              if not message:
                  break
  
              response = self.dispatcher.dispatch(message) or "OK"
  
              KERNEL32.WriteFile(
                  self.pipe_handle, response, len(response),
                  byref(bytes_written), None
              )
  
          KERNEL32.CloseHandle(self.pipe_handle)
function_tokens: def run ( self ) : buf = create_string_buffer ( BUFSIZE ) bytes_written = c_uint ( ) while self . do_run : message = self . _read_message ( buf ) if not message : break response = self . dispatcher . dispatch ( message ) or "OK" KERNEL32 . WriteFile ( self . pipe_handle , response , len ( response ) , byref ( bytes_written ) , None ) KERNEL32 . CloseHandle ( self . pipe_handle )