[streaming] Throwing exception when DataStreams of same type connected.