-record(stream, {buffer :: list(any()), cursor :: integer()}).