stream recieve queue