size computation in SkipOp

Arne Siegel v.a.ammodytes at
Sat Sep 22 05:28:51 PDT 2012

I'd expect the following computation in SkipOp.wrapSink() makes some sense:

        return new Sink.ChainedValue<T>(sink) {
            public void begin(int size) {
                downstream.begin(size < 0 ? size : size >= skip ? size - skip : 0);

If stream size gets computed in this way, FLAG_SIZED in SkipOp.getStreamFlags() doesn't 
need to be cleared.

Similarly for MapSkipOp.

Arne Siegel

More information about the lambda-dev mailing list