diff --git a/package.json b/package.json
index af429d3ac..fc285c7e4 100644
--- a/package.json
+++ b/package.json
@@ -8,7 +8,7 @@
 		"build": "npm run tsc",
 		"tsc": "tsc",
 		"tsd": "tsd",
-		"jest": "jest",
+		"jest": "jest --detectOpenHandles",
 		"test": "npm run jest && npm run tsd"
 	},
 	"repository": {
diff --git a/src/streaming.ts b/src/streaming.ts
index 7a809f19a..cc1b9a887 100644
--- a/src/streaming.ts
+++ b/src/streaming.ts
@@ -255,8 +255,7 @@ export default class Stream extends EventEmitter<StreamEvents> {
 	 */
 	@autobind
 	public close() {
-		this.stream.removeEventListener('open', this.onOpen);
-		this.stream.removeEventListener('message', this.onMessage);
+		this.stream.close();
 	}
 }
 
diff --git a/test/streaming.ts b/test/streaming.ts
index afd0852ff..7de85ce77 100644
--- a/test/streaming.ts
+++ b/test/streaming.ts
@@ -32,12 +32,14 @@ describe('Streaming', () => {
 			id: 'foo'
 		});
 
+		stream.close();
 		server.close();
 	});
 
+	/* TODO
 	test('useChannel with parameters', async () => {
-		// TODO
 	});
+	*/
 
 	test('Connection#dispose', async () => {
 		const server = new WS('wss://misskey.test/streaming');
@@ -68,6 +70,7 @@ describe('Streaming', () => {
 
 		expect(mainChannelReceived.length).toEqual(0);
 
+		stream.close();
 		server.close();
 	});