Replaces IObservable byte streams with proper streams