[streaming] Refactored stream components with InputHandler & OutputHandler