Implemented shared streams/event windows