def flush(self, n=4096):

        try:
            read = self.from_stream.read(n)

            if read is None or len(read) == 0:
                self.eof = True
                if self.propagate_close:
                    self.to_stream.close()
                return None

            return self.to_stream.write(read)
        except OSError as e:
            if e.errno != errno.EPIPE:
                raise e
Registers a user or updates its attributes using the contents of "user_dict". Updates
dataset/ETHPy150Open d11wtq/dockerpty/dockerpty/io.py/Pump.flush--crossover with--dataset/ETHPy150Open viewfinderco/viewfinder/backend/db/user.py/User.Register