diff --git a/erisdb/wsService.go b/erisdb/wsService.go
index d85cf41f4d493b9fa8dbb3099497b4ab029fd404..2af9bca00a382975815a3231da239b392ca237ad 100644
--- a/erisdb/wsService.go
+++ b/erisdb/wsService.go
@@ -105,8 +105,8 @@ func (this *ErisDbWsService) EventSubscribe(request *rpc.RPCRequest, requester i
 	}
 	callback := func(ret types.EventData) {
 		writeErr := this.writeResponse(subId, ret, session)
-		if(writeErr != nil){
-			this.pipe.Events().Unsubscribe(subId);
+		if writeErr != nil {
+			this.pipe.Events().Unsubscribe(subId)
 		}
 	}
 	_, errC := this.pipe.Events().Subscribe(subId, eventId, callback)