now the wal handler creates a stream of timeseries, followed by a 'you have processed the entire WAL, go ahead and nuke it' function