SchedLoop stream = scheduler.newSchedLoop (this, joiner.getSchedType (), bodySched, splitter.getSchedType (), loopSched, delay);
SchedLoop stream = scheduler.newSchedLoop (this, joiner.getSchedType (scheduler), bodySched, splitter.getSchedType (scheduler), loopSched, delay);
    SchedStream constructSchedule ()    {        // initialize the children        SchedStream bodySched = (body == null ? null : body.constructSchedule ());        SchedStream loopSched = (loop == null ? null : loop.constructSchedule ());        // create the loop        SchedLoop stream = scheduler.newSchedLoop (this, joiner.getSchedType (), bodySched, splitter.getSchedType (), loopSched, delay);        return stream;    }