comparison signals/@siglzcat/construct.m @ 1:289445d368a7

import.

+function s=construct(sig)
+	fs=rate(sig.head);
+	ch=channels(sig.head);
+	sc=construct(sig.head);
+	sx=sig.tail;
+
+	s.start   = @start;
+	s.stop    = @stop;
+	s.dispose = @dispose;
+	s.reader  = @reader;
+
+	function start, sc.start(); end
+	function stop, sc.stop(); end
+	function dispose, sc.dispose(); end 
+	function r=reader(n)
+		rc=sc.reader(n);
+		r = @next;
+		function [x,rem]=next
+			[x,rem]=rc();
+			while rem>0 && ~isempty(sx) % current signal exhausted, try next
+				sc.dispose();
+				[sig2,sx]=sx();
+
+				fs=unify_rates(fs,rate(sig2));
+				if isinf(fs), error('sigcat:Signal sampling rate mismatch'); end
+				ch=unify_channels(ch,channels(sig2));
+				if isinf(ch), error('sigcat:Signal channels count mismatch'); end
+				sc=construct(sig2); 
+
+				[x(:,end-rem+1:end),rem]=sigreadn(sc,rem);
+				rc=sc.reader(n);
+			end
+		end
+	end
+end