jens/flipper
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix unhandled promise rejections at startup

Browse Source 
Summary: I like the idea, but these reject by default promises cause the global rejection handler to fire at startup, looking like things are broken.

Reviewed By: danielbuechele

Differential Revision: D17397614

fbshipit-source-id: 88601d6c65cb79d61efc27c34a4b7f2dd8716d39
This commit is contained in:
John Knox
2019-09-16 09:46:30 -07:00
committed by Facebook Github Bot
parent 2fcd0cbcac
commit ea4b62c458
1 changed files with 9 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/server.tsx
View File

@@ -41,13 +41,13 @@ declare interface Server {
class Server extends EventEmitter {
connections: Map<string, ClientInfo>;
secureServer: Promise<RSocketServer<any, any>>;
insecureServer: Promise<RSocketServer<any, any>>;
secureServer: Promise<RSocketServer<any, any>> | null;
insecureServer: Promise<RSocketServer<any, any>> | null;
certificateProvider: CertificateProvider;
connectionTracker: ConnectionTracker;
logger: Logger;
store: Store;
initialisePromise: Promise<void>;
initialisePromise: Promise<void> | null;
constructor(logger: Logger, store: Store) {
super();
@@ -55,12 +55,9 @@ class Server extends EventEmitter {
this.connections = new Map();
this.certificateProvider = new CertificateProvider(this, logger);
this.connectionTracker = new ConnectionTracker(logger);
// eslint-disable-next-line prefer-promise-reject-errors
this.secureServer = Promise.reject();
// eslint-disable-next-line prefer-promise-reject-errors
this.insecureServer = Promise.reject();
// eslint-disable-next-line prefer-promise-reject-errors
this.initialisePromise = Promise.reject();
this.secureServer = null;
this.insecureServer = null;
this.initialisePromise = null;
this.store = store;
}
@@ -280,8 +277,9 @@ class Server extends EventEmitter {
if (this.initialisePromise) {
return this.initialisePromise.then(_ => {
return Promise.all([
this.secureServer.then(server => server.stop()),
this.insecureServer.then(server => server.stop()),
this.secureServer && this.secureServer.then(server => server.stop()),
this.insecureServer &&
this.insecureServer.then(server => server.stop()),
]).then(() => undefined);
});
}