moved query streaming into separate actor