comparison sinks/@sinkcat/construct.m @ 0:672052bd81f8

Initial partial import.

+function s=construct(sig)
+	sc=construct(sig.sinks{1});
+	sx=sig.sinks(2:end);
+
+	s.start   = @start;
+	s.stop    = @stop;
+	s.dispose = @dispose;
+	s.writer  = @writer;
+
+	function start, sc.start(); end
+	function stop, sc.stop(); end
+	function dispose, sc.dispose(); end 
+
+	function r=writer(n)
+		rc=sc.writer(n);
+		r = @next;
+		function rem=next(x)
+			rem=rc(x);
+			while rem>0 && ~isempty(sx) % current signal exhausted, try next
+				sc.dispose();
+				sc=construct(sx{1}); sx=sx(2:end);
+				rem=sinkwriten(sc,n,x(end-rem+1:end));
+				rc=sc.writer(n);
+			end
+		end
+	end
+end