Stream merge: Difference between revisions

static class StreamMerge

static IEnumerable<T> Merge2<T>(IEnumerable<T> i1source1, IEnumerable<T> i2source2) where T : IComparable

var q1 = new Queue<T>(i1source1);

var q2 = new Queue<T>(i2source2);

static IEnumerable<T> MergeN<T>(params IEnumerable<T>[] enumerablessources) where T : IComparable

var queues = enumerablessources.Select(e => new Queue<T>(e)).Where(q => q.Any()).ToList();

var queueWithLowestItemq = queues.AggregateFirst((q1, q2) => q1.Peek().CompareTo(q2.Peek()) <= 0 ? q1 : q2);

yield return queueWithLowestItemqueues.DequeueRemoveAt(0);

ifyield (!queueWithLowestItem.Any())return queuesq.RemoveDequeue(queueWithLowestItem);

static void Main(string[] args)