tink_io
tink_io copied to clipboard
Asynchronous I/O everywhere
https://github.com/haxetink/tink_io/blob/gh-pages/README.md#memory-management It seems the example code here is unfinished by accident. Or does the trace statement actually interfere with the garbage collection?
Mainly changed the following: ```diff interface StreamParserObject { - function eof(rest:ChunkCursor):Outcome; + function eof(rest:ChunkCursor):Outcome; } ``` Rationale: an eof of a stream might come "detached" from any data. For example...
example: ```haxe function uploadToCloud(chunk:Chunk):Promise; new CollectSink(uploadToCloud); // a sink with result typed as Noise ```
Trying to rewrite [this code](https://github.com/kevinresol/why-fs/blob/58a2e78/src/why/fs/S3.hx#L56-L68) to use OutputSink + BytesOutput. The idea is to return a sink from the function for the user to `pipeTo`, when the sink is ended...
https://github.com/haxetink/tink_io/commit/f703868abde4400a1db7d83797794dd07e6e454e is a failing test but I have completely no idea how to fix. I guess it is something related to streams. Because the iteration doesn't seem to halt after...
Should help https://github.com/haxetink/tink_io/issues/36 but I don't think this is the best solution.
Especially file descriptors must be closed. If part of a file source is piped somewhere and the rest is never read, it should be possible to close the source (and...
Followup on #18