code: def process_chunks(self, chunks):
          
          chunk, = chunks
          if chunk.keys:
              self.result[chunk.keys] = chunk.data
          else:
              self.result[...] = chunk.data
docs: Store the incoming chunk at the corresponding position in the
          result array.