Interface ResultSender<T>


  • public interface ResultSender<T>
    Provides methods to send results back to the ResultCollector. A ResultSender adds the ability for an execute method to send a single result back, or break its result into multiple pieces and send each piece back to the calling thread's ResultCollector. For each result sent using this method, ResultCollector.addResult(org.apache.geode.distributed.DistributedMember, Object) is called, making that result available to the calling thread immediately.

    Example:

    
          execute(FunctionContext context){
                  ResultSender rs = context.getResultSender();
                  int lastResult = -1;
                  for(int i=0;i< 10; i++) {
                          rs.sendResult(i);
                  }
                  rs.lastResult(lastResult);
          }
    
      Application can receive the results as they are sent using ResultSender in the above for loop.
      It is very important to send a last result as it informs ResultCollector
      to stop waiting for the result.
     
    Since:
    GemFire 6.0
    See Also:
    ResultCollector.addResult(org.apache.geode.distributed.DistributedMember, Object)