Add streaming capabilities to both the listen task and to the asyncapi (subscribe operation) call

Add streaming capabilities to both the listen task and to the asyncapi (subscribe operation) call #1668