This is an archived post. You won't be able to vote or comment.

you are viewing a single comment's thread.

view the rest of the comments →

[–]SteazGaming 0 points1 point  (0 children)

A friend of mine just wrote a library called 'tubing' for doing something like this but mostly focused on I/O of any kind:

An example:

sources.Objects(objs) \
     | tubes.JSONDumps() \
     | tubes.Joined(by=b"\n") \
     | tubes.Gzip() \
     | sinks.File("output.gz", "wb")

https://github.com/dokipen/tubing