| /** PURE_IMPORTS_START _Subscriber,_symbol_rxSubscriber,_Observer PURE_IMPORTS_END */ | 
| import { Subscriber } from '../Subscriber'; | 
| import { rxSubscriber as rxSubscriberSymbol } from '../symbol/rxSubscriber'; | 
| import { empty as emptyObserver } from '../Observer'; | 
| export function toSubscriber(nextOrObserver, error, complete) { | 
|     if (nextOrObserver) { | 
|         if (nextOrObserver instanceof Subscriber) { | 
|             return nextOrObserver; | 
|         } | 
|         if (nextOrObserver[rxSubscriberSymbol]) { | 
|             return nextOrObserver[rxSubscriberSymbol](); | 
|         } | 
|     } | 
|     if (!nextOrObserver && !error && !complete) { | 
|         return new Subscriber(emptyObserver); | 
|     } | 
|     return new Subscriber(nextOrObserver, error, complete); | 
| } | 
| //# sourceMappingURL=toSubscriber.js.map |