sj.getSplitter().isUnaryRoundRobin() ||
    private static SIRPipeline makeFusedPipe(SIRSplitJoin sj,                                             SRepInfo rep,                                             SRate rate,                                             SIRFilter newFilter) {        SIRPipeline pipe = new SIRPipeline(sj.getParent(), newFilter.getName() + "_Wrap");        // make a dummy init function        pipe.setInit(SIRStream.makeEmptyInit());        // do not make a filter for a splitter if:        //  - it's a duplicate        //  - it's a roundrobin(1,1,...,1)        //  - it's a null split        if (!(sj.getSplitter().getType()==SIRSplitType.DUPLICATE ||              sj.getSplitter().isUnaryRoundRobin() ||              rep.splitter==0 ||              // don't need a splitter filter if the splitter only              // executes once, since it would preserve the order of the items              rep.splitter==1              )) {            pipe.add(makeFilter(pipe,                                "Pre_" + sj.getIdent(),                                makeSplitFilterBody(sj.getSplitter(),                                                    rep,                                                    sj.getInputType()),                                rate.pop, rate.pop, rate.pop,                                sj.getInputType()));        }        int index = sj.getParent().indexOf(sj);        assert index>-1:            "Couldn't find " + sj.getName() + " in " +            sj.getParent().getIdent();        // don't bother adding identity filters to the pipeline        if (!(newFilter instanceof SIRIdentity)) {            pipe.add(newFilter, new LinkedList(sj.getParent().getParams(index)));        }        // make a joinFilter only if it's not a not a null join        if (rep.joiner!=0 &&            // don't need a joiner filter if the joiner only executes            // once, because it would preserve the order of the items            rep.joiner!=1) {            pipe.add(makeFilter(pipe,                                "Post_" + sj.getIdent(),                                makeJoinFilterBody(sj.getJoiner(),                                                   rep,                                                   sj.getOutputType()),                                rate.push, rate.push, rate.push,                                sj.getOutputType()));        }        // if we didn't add anything, add an identity filter        if (pipe.size()==0) {            pipe.add(new SIRIdentity(sj.getInputType()));        }        return pipe;    }