Finished reimplementing claimed tasks stream filter. Part of #932