passOneData(input[nCh], output);
passOneData(inputChannel[nCh], outputChannel);
    public void work()    {        int throughput[] =            (sjIter != null             ? sjIter.getJoinPopWeights(nWork)             : flIter.getJoinPopWeights(nWork));        int totalWork =            (sjIter != null             ? sjIter.getJoinerNumWork()             : flIter.getJoinerNumWork());        nWork++;        nWork = nWork % totalWork;        for (int nCh = 0; nCh < srcs.size(); nCh++)            {                for (int nData = 0; nData < throughput[nCh]; nData++)                    {                        passOneData(input[nCh], output);                    }            }    }