0

私はサンプルのコルドバ/イオンアプリを開発しています。angular2/typescript を使用しています。node.js サーバーからのイベント ストリームを処理する GET 要求を発行しました。このつながりを閉じたいと思います。どうやってやるの？

ionViewWillEnter(){

// Register for SSE Events
var sseUrl = this.hostUrl + '/api/v1/br/notifications';

this.response = this.http.get(sseUrl).map(res => res.json());
this.response.subscribe(
    data => {
      doSomething(data);
    },
    err => console.error(err));
}

ionViewWillLeave(){
    // What should I do here??
}

サーバー側のコードは次のとおりです。

//API: POST /notifications
function getNotifications(req, res){
     req.socket.setTimeout(0);
     addListeners(res, notify);

     //send headers for event-stream connection
     res.writeHead(200, {
        'Content-Type': 'text/event-stream',
        'Cache-Control': 'no-cache',
        'Connection': 'keep-alive'
     });
     res.write('\n');

     req.on("close", function() {
        console.log("Close called...");
        removeListener(res);
    });
}

function notify(data, notifier){
    console.log(util.format('Sending: Data: %s', data));
    notifier.res.write('data: ' + data + '\n\n'); // Note the extra newline
}
4

1 に答える 1

3

.subscribe()Subscription購読を解除できる を返します。

this.subscription = this.response.subscribe(
    data => {
      doSomething(data);
    },
    err => console.error(err));
}

...

this.subscription.unsubscribe();
于 2016-06-20T12:16:44.643 に答える