Added freezing of event streams to indicate a source
Added reduce function