Substract on non ordered streams produces incorrect result

[nicolasjolet]

Hi again :-)

It seems that an issue is hidding in the Substract operator on non ordered streams.

Considering the following example:

var stream1 = contextStream
    .CrossApply("create values from enumeration", ctx => Enumerable.Range(1, 100)
        .Select(i => new { Id = i, Label = $"Label{i}" }));
var stream2 = contextStream
    .CrossApply("create values from enumeration2", ctx => Enumerable.Range(1, 8)
        .Select(i => new { Id = i, Label = $"OtherLabel{i}" }));
var res = stream1.Substract("merge with stream 2", stream2, i => i.Id, i => i.Id)
   .Do("print console", i => Console.WriteLine(i.Label));

The previous code produces only 1 row (Label100) instead of 92 rows.

No issue when using ordered streams and the method
public static IStream<TInLeft> Substract<TInLeft, TInRight, TKey>(this ISortedStream<TInLeft, TKey> leftStream, string name, ISortedStream<TInRight, TKey> rightStream).

(version 2.0.23)

[paillave]

will look at it; I'll let U know.

[paillave]

will look at it; I'll let U know.

@nicolasjolet A new version containing the fix is deployed since couple of days.