Added StreamedQueue test