Added a new method U.aistreamer(on_line, on_message).

Author: petersirka

changelog.txt

@@ -19,6 +19,7 @@
 - fixed Total error handling
 - improved compiling navigation in the CMS compiler
 - fixed filling of the `template` property in the CMS compiler
+- added a new method `U.aistreamer(on_line, on_message)`
 
 ========================
 0.0.15

utils.js

@@ -1565,6 +1565,27 @@ exports.streamer2 = function(beg, end, callback, skip, stream) {
 	return exports.streamer(beg, end, callback, skip, stream, true);
 };
 
+exports.aistreamer = function(online, onmessage) {
+	let buffer = '';
+	let c = '\n';
+	let date = onmessage != null;
+	return U.streamer(c, function(line) {
+		let obj = line.parseJSON(date);
+		if (obj) {
+			buffer += obj.message.content;
+			let index = 0;
+			while (index != -1) {
+				index = buffer.indexOf(c);
+				if (index != -1) {
+					online && online(buffer.substring(0, index));
+					buffer = buffer.substring(index + 1);
+				}
+			}
+			onmessage && onmessage(obj);
+		}
+	});
+};
+
 exports.filestreamer = function(filename, onbuffer, onend, size) {
 
 	if (typeof(onend) === 'number') {