1 import { Subscriber } from '../Subscriber';
2 import { rxSubscriber as rxSubscriberSymbol } from '../symbol/rxSubscriber';
3 import { empty as emptyObserver } from '../Observer';
4 export function toSubscriber(nextOrObserver, error, complete) {
6 if (nextOrObserver instanceof Subscriber) {
9 if (nextOrObserver[rxSubscriberSymbol]) {
10 return nextOrObserver[rxSubscriberSymbol]();
13 if (!nextOrObserver && !error && !complete) {
14 return new Subscriber(emptyObserver);
16 return new Subscriber(nextOrObserver, error, complete);
18 //# sourceMappingURL=toSubscriber.js.map