protected Object getNextReplyObject() {
      throw new UnsupportedOperationException(
          "use getNextReplyObject(PartitionedRegion) instead");
    }
override in subclass to provide reply data. terminate by returning END_OF_STREAM token object
geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/StreamingPartitionOperation.java