-record(next, {item :: any(), rest :: ssevents@stream:iterator(any())}).