angular 2, if 문에 따라 Observables를 반환하십시오.

Question

안녕하세요. 이와 비슷한 것을 만들고 싶습니다.

someFunction():Observable<Response>{ 
    let response$ = new Observerable(); 

    if (...){ 
    response$ = this.http.get(url1) 
    }else{ 
    response$ = this.http.get(url2) 
    } 
    return response$ 
} 

내가 가입하면 , 내가

재산을 읽을 사전에있는 모든 도움을

정의되지 않은 감사의 '구독'할 수 없습니다

오류를 받고 있어요!

EDIT --------- 이것은 이온 2와 코드 바를 사용하는 실제 기능입니다. 앱이 휴대 기기에 있는지 여부를 확인하고 URL이 팝업으로 열립니다 (소셜 로그인에 사용 예정)

일단 창이 닫히면 http.get 요청을 수행하여 토큰을 가져와야합니다 내 백엔드에서.

public social(providerName:string):Observable<Response>{ 

let response$ = new Observable<Response>(); 
let url =providerName+'/someUrl' 

let authWindow; 

if(window.cordova){ 
    let authWindow= InAppBrowser.open(url, '_blank', 'location=no'); 

    authWindow.addEventListener('loadstop', event => { 
     if(event.url.indexOf(`${providerName}/callback`) > -1){ 
      authWindow.close() 
     } 
    }); 

    authWindow.addEventListener('loaderror', event =>{ 
     if(event.url.indexOf(`${providerName}/callback`) > -1){ 
      authWindow.close() 
     } 
    }); 

    authWindow.addEventListener('exit',() => { 
     setTimeout(()=>{ 
      response$ = this.http.get(...) 
     },500) 
    }) 

}else{ 
    authWindow = createWindow(popupUrl); 
    let window = Observable.interval(1000); 

    let pingWindow = window.subscribe(
     ()=>{ 
      if(authWindow.closed){ 
       pingWindow.unsubscribe(); 

       response$ = this.http.get(...) 

      } 
     }) 
} 

return response$ 

}

Answer 1

업데이트는 문제를 보여줍니다.
response$에 직접 할당되지만 비동기 콜백에 할당되지 않습니다. return response$가 실행되면, response$

setTimeout(()=>{ 
     response$ = this.http.get(...) 
    },500) 

도

let pingWindow = window.subscribe(
    ()=>{ 
     if(authWindow.closed){ 
      pingWindow.unsubscribe(); 

      response$ = this.http.get(...) 

     } 
    }) 

에 할당 것도 아직 실행되지 않았다.

첫 번째는 0.5 초 후에 실행되고 window.subscribe(...)에 전달 된 함수는 일부 포인트가 될 방출 값 때문에 실행됩니다.

public social(providerName:string):Observable<Response>{ 

    let response$ = new Subject<Response>(); 
    let url =providerName+'/someUrl' 

    let authWindow; 

    if(window.cordova){ 
     let authWindow= InAppBrowser.open(url, '_blank', 'location=no'); 

     authWindow.addEventListener('loadstop', event => { 
      if(event.url.indexOf(`${providerName}/callback`) > -1){ 
       authWindow.close() 
      } 
     }); 

     authWindow.addEventListener('loaderror', event =>{ 
      if(event.url.indexOf(`${providerName}/callback`) > -1){ 
       authWindow.close() 
      } 
     }); 

     authWindow.addEventListener('exit',() => { 
      setTimeout(()=>{ 
       this.http.get(...) 
       .map(val => val.json()) 
       .subscribe(val => response$.next(val); 
      },500) 
     }) 

    }else{ 
     authWindow = createWindow(popupUrl); 
     let window = Observable.interval(1000); 

     let pingWindow = window.subscribe(
      ()=>{ 
       if(authWindow.closed){ 
        pingWindow.unsubscribe(); 

        this.http.get(...) 
        .map(val => val.json()) 
        .subscribe(val => response$.next(val); 
       } 
      }) 
    } 

    return response$.asObservable() 
} 

최소한의 문제는 해결되어야합니다.