High-level (object) streaming library for Erlang