diff options
| author | Florian Fischer <florian.fischer@muhq.space> | 2023-07-31 18:21:31 +0200 |
|---|---|---|
| committer | Florian Fischer <florian.fischer@muhq.space> | 2023-07-31 18:21:31 +0200 |
| commit | c0aefddb1ee75d4d0a36d8db197755469687bfc8 (patch) | |
| tree | f8da1d29cb2865693256c3944435d97f0f912457 /wrms.go | |
| parent | 157867933ff77037555983eb9c085e8e9471a348 (diff) | |
| download | WRMS-c0aefddb1ee75d4d0a36d8db197755469687bfc8.tar.gz WRMS-c0aefddb1ee75d4d0a36d8db197755469687bfc8.zip | |
panic when data to send to a client can not be marshaled
Diffstat (limited to 'wrms.go')
| -rw-r--r-- | wrms.go | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -77,7 +77,7 @@ func (wrms *Wrms) delConn(conn *Connection) { } } -func (wrms *Wrms) initConn(conn *Connection) error { +func (wrms *Wrms) initConn(conn *Connection) { wrms.rwlock.RLock() curEventId := wrms.eventId.Load() @@ -123,7 +123,7 @@ func (wrms *Wrms) initConn(conn *Connection) error { wrms.rwlock.RUnlock() llog.Info("Sending initial cmds %v", initialCmds) - return conn._send(initialCmds) + conn._send(initialCmds) } func (wrms *Wrms) GetConn(connId uuid.UUID) *Connection { |