fix: subscriber's OnCompleted cannot seem to ber called from observable. OnCompleted made intenally from OnNext now