protected PartitionMessage createRequestMessage(InternalDistributedMember recipient,
      ReplyProcessor21 processor, FunctionRemoteContext context) {
    PartitionedRegionFunctionStreamingMessage msg =
        new PartitionedRegionFunctionStreamingMessage(recipient, regionId, processor, context);

    return msg;
  }
Returns normally if succeeded to get data, otherwise throws an exception Have to wait outside
this function and when getResult() is called. For the time being get the correct results.
geode-core/src/main/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultWaiter.java