Update Stream to v12

examples/StreamImplSimpleProtocol2.hx

@@ -13,7 +13,7 @@ class SimpleProtocol extends Transform<SimpleProtocol> {
 	var _rawHeader = [];
 	var header:Buffer;
 
-	override function _transform(chunk:Buffer, encoding, callback) {
+	override function _transform(chunk:Dynamic, encoding, callback) {
 		if (!this._inBody) {
 			// check if the chunk has a \n\n
 			var split = -1;

src/js/node/Stream.hx

@@ -22,14 +22,46 @@
 
 package js.node;
 
+import haxe.extern.Rest;
+import js.node.stream.Writable.IWritable;
 import js.node.events.EventEmitter;
+import js.node.stream.Readable.IReadable;
+#if haxe4
+import js.lib.Error;
+import js.lib.Promise;
+#else
+import js.Error;
+import js.Promise;
+#end
 
 /**
 	Base class for all streams.
 **/
 @:jsRequire("stream") // the module itself is also a class
 extern class Stream<TSelf:Stream<TSelf>> extends EventEmitter<TSelf> implements IStream {
 	private function new();
+
+	/**
+		A module method to pipe between streams forwarding errors and properly cleaning up
+		and provide a callback when the pipeline is complete.
+
+		@see https://nodejs.org/api/stream.html#stream_stream_pipeline_streams_callback
+	**/
+	@:overload(function(readable:IReadable, callback:Null<Error>->Void):Void {})
+	@:overload(function(readable:IReadable, writable1:IWritable, callback:Null<Error>->Void):Void {})
+	@:overload(function(readable:IReadable, writable1:IWritable, writable2:IWritable, callback:Null<Error>->Void):Void {})
+	@:overload(function(readable:IReadable, writable1:IWritable, writable2:IWritable, writable3:IWritable, callback:Null<Error>->Void):Void {})
+	@:overload(function(readable:IReadable, writable1:IWritable, writable2:IWritable, writable3:IWritable, writable4:IWritable,
+		callback:Null<Error>->Void):Void {})
+	@:overload(function(readable:IReadable, writable1:IWritable, writable2:IWritable, writable3:IWritable, writable4:IWritable, writable5:IWritable,
+		callback:Null<Error>->Void):Void {})
+	@:overload(function(readable:IReadable, writable1:IWritable, writable2:IWritable, writable3:IWritable, writable4:IWritable, writable5:IWritable,
+		writable6:IWritable, callback:Null<Error>->Void):Void {})
+	@:overload(function(readable:IReadable, writable1:IWritable, writable2:IWritable, writable3:IWritable, writable4:IWritable, writable5:IWritable,
+		writable6:IWritable, writable7:IWritable, callback:Null<Error>->Void):Void {})
+	@:overload(function(readable:IReadable, writable1:IWritable, writable2:IWritable, writable3:IWritable, writable4:IWritable, writable5:IWritable,
+		writable6:IWritable, writable7:IWritable, writable8:IWritable, callback:Null<Error>->Void):Void {})
+	static function pipeline(readable:IReadable, streams:Rest<IWritable>):Promise<Void>;
 }
 
 /**

src/js/node/http/ClientRequest.hx

@@ -207,16 +207,9 @@ extern class ClientRequest extends Writable<ClientRequest> {
 	 */
 	var socket(default, null):Socket;
 
-	/**
-		Is `true` after `request.end()` has been called.
-		This property does not indicate whether the data has been flushed, for this use `request.writableFinished` instead.
-	**/
-	var writableEnded(default, null):Bool;
-
-	/**
-		Is `true` if all data has been flushed to the underlying system, immediately before the `'finish'` event is emitted.
-	**/
-	var writableFinished(default, null):Bool;
+	// This field is defined in super class.
+	// var writableEnded(default, null):Bool;
+	// var writableFinished(default, null):Bool;
 }
 
 typedef InformationEventData = {

src/js/node/http/IncomingMessage.hx

@@ -69,7 +69,7 @@ extern class IncomingMessage extends Readable<IncomingMessage> {
 		Calls `destroy()` on the socket that received the `IncomingMessage`.
 		If `error` is provided, an `'error'` event is emitted and `error` is passed as an argument to any listeners on the event.
 	**/
-	function destroy(?error:Error):Void;
+	override function destroy(?error:Error):IncomingMessage;
 
 	/**
 		The request/response headers object.

src/js/node/http/ServerResponse.hx

@@ -168,17 +168,6 @@ extern class ServerResponse extends Writable<ServerResponse> {
 	**/
 	var statusMessage:String;
 
-	/**
-		Is `true` after `end()` has been called. This property does not indicate whether the data has been flushed,
-		for this use `writableFinished` instead.
-	**/
-	var writableEnded(default, null):Bool;
-
-	/**
-		Is `true` if all data has been flushed to the underlying system, immediately before the `'finish'` event is emitted.
-	**/
-	var writableFinished(default, null):Bool;
-
 	/**
 		Sends a HTTP/1.1 100 Continue message to the client, indicating that the request body should be sent.
 		See the `'checkContinue'` event on `Server`.
@@ -214,4 +203,8 @@ extern class ServerResponse extends Writable<ServerResponse> {
 		Sends a HTTP/1.1 102 Processing message to the client, indicating that the request body should be sent.
 	**/
 	function writeProcessing():Void;
+
+	// This field is defined in super class.
+	// var writableEnded(default, null):Bool;
+	// var writableFinished(default, null):Bool;
 }

src/js/node/net/Socket.hx

@@ -249,9 +249,12 @@ extern class Socket extends js.node.stream.Duplex<Socket> {
 	/**
 		A boolean value that indicates if the connection is destroyed or not.
 		Once a connection is destroyed no further data can be transferred using it.
+
+		define in Stream/Readable.hx
 	**/
-	var destroyed(default, null):Bool;
+	// var destroyed(default, null):Bool;
 
+	#if haxe4
 	/**
 		Ensures that no more I/O activity happens on this socket.
 		Only necessary in case of errors (parse error or so).
@@ -260,6 +263,7 @@ extern class Socket extends js.node.stream.Duplex<Socket> {
 		any listeners for that event will receive exception as an argument.
 	**/
 	function destroy(?exception:Error):Void;
+	#end
 
 	/**
 		Sets the socket to timeout after `timeout` milliseconds of inactivity on the socket.