From 803290932de8a15c97c6d7e3a6f1720fb0745361 Mon Sep 17 00:00:00 2001
From: czp <czp3009@gmail.com>
Date: Fri, 9 Feb 2018 09:32:25 +0800
Subject: [PATCH] =?UTF-8?q?=E5=B0=86=20LiveClient=20=E4=B8=AD=E7=9A=84=20C?=
 =?UTF-8?q?onnectionClose=20=E7=9B=91=E5=90=AC=E5=99=A8=E5=8F=98=E4=B8=BA?=
 =?UTF-8?q?=E5=86=85=E9=83=A8=E7=B1=BB=E4=BB=A5=E9=98=B2=E6=AD=A2=E5=A4=96?=
 =?UTF-8?q?=E9=83=A8=E7=9B=B4=E6=8E=A5=E8=B0=83=E7=94=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../bilibili/api/live/socket/LiveClient.java     | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/hiczp/bilibili/api/live/socket/LiveClient.java b/src/main/java/com/hiczp/bilibili/api/live/socket/LiveClient.java
index a4d6c33..f86b715 100644
--- a/src/main/java/com/hiczp/bilibili/api/live/socket/LiveClient.java
+++ b/src/main/java/com/hiczp/bilibili/api/live/socket/LiveClient.java
@@ -39,6 +39,10 @@ public class LiveClient implements Closeable {
     private EventLoopGroup eventLoopGroup;
     private Channel channel;
 
+    private void initEventBus() {
+        eventBus.register(new ConnectionCloseListener());
+    }
+
     public LiveClient(BilibiliServiceProvider bilibiliServiceProvider, long showRoomId) {
         this.bilibiliServiceProvider = bilibiliServiceProvider;
         this.showRoomId = showRoomId;
@@ -53,10 +57,6 @@ public class LiveClient implements Closeable {
         initEventBus();
     }
 
-    private void initEventBus() {
-        eventBus.register(this);
-    }
-
     public synchronized LiveClient connect() throws IOException {
         if (channel != null && channel.isActive()) {
             LOGGER.warn("Already connected to server, connect method can not be invoked twice");
@@ -130,9 +130,11 @@ public class LiveClient implements Closeable {
         }
     }
 
-    @Subscribe
-    public void onConnectionClose(ConnectionCloseEvent connectionCloseEvent) {
-        eventLoopGroup.shutdownGracefully();
+    private class ConnectionCloseListener {
+        @Subscribe
+        public void onConnectionClose(ConnectionCloseEvent connectionCloseEvent) {
+            eventLoopGroup.shutdownGracefully();
+        }
     }
 
     public EventBus getEventBus() {