Put the AsyncStreams activity in a service, and then your Activities can call a sub in the service to get the new data.
Or, if certain data only goes to certain activities, then the service can route it correctly and call an activity sub.
I have an app that does something like that with an httpjob; the principle's similar - in my case, I check the job name, and use a case statement to select which activity the results have to go back to; you might check the start of the data, or just go through the activities to see if they're paused or not - and then call a sub back in the appropriate activity to process the data.