Real-time data stream filter