node.js - 如何关闭在 Angular2 中创建的 HTTP 连接？

Question

我正在开发一个示例 cordova/ionic 应用程序。我正在使用 angular2/typescript。我发出了一个 GET 请求，让我可以处理来自 node.js 服务器的事件流。我想关闭这个连接。我怎样才能做到这一点？

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
}

Answer 1

.subscribe()返回一个Subscription允许您取消订阅的：

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

...

this.subscription.unsubscribe();