[streaming] Added exceptions
[streaming] Javadoc update for some core classes