1. Added Observable and Producer implementations (Producer is a Task based observable)
2. Added unit tests for Observable and Producer implementations