size computation in SkipOp
Arne Siegel
v.a.ammodytes at googlemail.com
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) {
...
@Override
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.
Regards
Arne Siegel
More information about the lambda-dev
mailing list