protected void processTuple(T tuple){
  Future<Slice> valFuture=getAsyncManagedState(tuple);
  if (valFuture.isDone()) {
    try {
      processEvent(tuple,valFuture.get());
    }
 catch (    InterruptedException|ExecutionException e) {
      throw new RuntimeException(e);
    }
  }
 else {
    processWaitingEvent(tuple,valFuture);
  }
}

protected void processTuple ( T tuple ) { Future < Slice > valFuture = getAsyncManagedState ( tuple ) ; if ( valFuture . isDone ( ) ) { try { processEvent ( tuple , valFuture . get ( ) ) ; } catch ( InterruptedException | ExecutionException e ) { throw new RuntimeException ( e ) ; } } else { processWaitingEvent ( tuple , valFuture ) ; } }
processes an incoming tuple
