[streaming] Fixed generics and added SuppressWarnings