Last is working, however it always returns data even if it is null, perhaps fix so that it returns reduced data
Also need to implement the ability to emit in chunks (e.g. wait for the number of events and then emit all at once)