code: def updateQueue(self):
          
          for future in self.socket.recvFuture():
              if future._ended():
                  # If the answer is coming back, update its entry
                  try:
                      thisFuture = scoop._control.futureDict[future.id]
                  except KeyError:
                      # Already received?
                      scoop.logger.warn('{0}: Received an unexpected future: '
                                        '{1}'.format(scoop.worker, future.id))
                      continue
                  thisFuture.resultValue = future.resultValue
                  thisFuture.exceptionValue = future.exceptionValue
                  thisFuture.executor = future.executor
                  thisFuture.isDone = future.isDone
                  # Execute standard callbacks here (on parent)
                  thisFuture._execute_callbacks(CallbackType.standard)
                  self.append(thisFuture)
                  future._delete()
              elif future.id not in scoop._control.futureDict:
                  scoop._control.futureDict[future.id] = future
                  self.append(scoop._control.futureDict[future.id])
              else:
                  self.append(scoop._control.futureDict[future.id])
docs: Process inbound communication buffer.
          Updates the local queue with elements from the broker.