Skip to content
Snippets Groups Projects
Commit 98308e09 authored by androlo's avatar androlo
Browse files

Merge branch 'master' into fix_versions

parents d6b91e77 89609eb8
No related branches found
No related tags found
No related merge requests found
......@@ -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)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment