Package org.apache.geode.cache.execute

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: