Created BackPressureWatcher to handle logic of applying back pressure