diff --git a/example/App.tsx b/example/App.tsx
index cbb3e53..9f87afd 100644
--- a/example/App.tsx
+++ b/example/App.tsx
@@ -10,22 +10,24 @@ export default function App() {
   const [started, setStarted] = React.useState(false);
 
   React.useEffect(() => {
-    broker.current.on('error', (err: Error) => {
+    const currBroker = broker.current;
+
+    currBroker.on('error', (err: Error) => {
       setError(err);
       console.error(err);
     });
-    broker.current.on('close', () => {
+    currBroker.on('close', () => {
       setStarted(false);
     });
-    broker.current.on('listening', () => {
+    currBroker.on('listening', () => {
       setStarted(true);
     });
-    broker.current.on('message', (topic: string, message: Buffer | string) => {
+    currBroker.on('message', (topic: string, message: Buffer | string) => {
       console.log('message', topic, message);
     });
-    broker.current.start();
+    currBroker.start();
 
-    return () => broker.current.stop();
+    return () => currBroker.stop();
   }, []);
 
   const stop = React.useCallback(() => {
@@ -40,12 +42,16 @@ export default function App() {
     <View style={styles.container}>
       {started && <Text>Run MQ broker on port 1883</Text>}
       {error && <Text>{error.message}</Text>}
-      {started && <Pressable onPress={stop} style={styles.box}>
-        <Text>Stop</Text>
-      </Pressable>}
-      {!started && <Pressable onPress={start} style={styles.box}>
-        <Text>Start</Text>
-      </Pressable>}
+      {started && (
+        <Pressable onPress={stop} style={styles.box}>
+          <Text>Stop</Text>
+        </Pressable>
+      )}
+      {!started && (
+        <Pressable onPress={start} style={styles.box}>
+          <Text>Start</Text>
+        </Pressable>
+      )}
     </View>
   );
 }
diff --git a/src/index.ts b/src/index.ts
index d7a3eb5..390beaf 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -124,8 +124,7 @@ export class Server extends EventEmitter {
   constructor(opts?: Object) {
     super();
     this._opts = opts;
-    this.server = net.createServer();
-    this.server.on('connection', (socket: net.Socket) => {
+    this.server = net.createServer((socket: net.Socket) => {
       this.emit('connection', new Client(socket, this._opts));
     });
     this.server.on('error', this.emit.bind(this, 'error'));