@Override
    public void transform(StreamToLoopReplacementContext context, String item) {
      createVariable(context, item);
      myDownstreamCollector.transform(context, myVariable.getName());
    }
@Override
    public void transform(StreamToLoopReplacementContext context, String item)