apis

current.hx

interface IReadable {
	final dataSignal:Signal<Bytes>;
	final endSignal:Signal<NoData>;
	final errorSignal:Signal<Error>;
	final pauseSignal:Signal<NoData>;
	final resumeSignal:Signal<NoData>;
	function resume():Void;
	function pause():Void;
	function pipe(target:IWritable):Void;
}

interface IWritable {
	final drainSignal:Signal<NoData>;
	final finishSignal:Signal<NoData>;
	final pipeSignal:Signal<IReadable>;
	final unpipeSignal:Signal<IReadable>;
	function write(chunk:Bytes):Bool;
	function end():Void;
	function cork():Void;
	function uncork():Void;
}

simple.hx

interface IReadable {
	function read(target:Bytes, offset:Int, length:Int, (error:Error, bytesRead:Int)>Void);
	function close():Void;
	//optional
	function prepare(capacity:Int):Void;
}

interface IWritable {
	function write(target:Bytes, offset:Int, length:Int, (error:Error, bytesRead:Int)>Void);
	function close():Void;
	//optional
	function flush():Void;
	function prepare(capacity:Int):Void;
}