code: def readeach(self, stream, **kwargs):
          
          for o in self.reader.loadeach(stream):
              yield o
docs: Temporary hook for API while streaming reads are in experimental
          phase. Read each object from stream as available with generator.
          JSON blocks indefinitely waiting on JSON entities to arrive. MsgPack
          requires unpacker property to be fed stream using unpacker.feed()
          method.