Move to stateless implementation of Streams to prevent dreaded FRP 'time leaks'