mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-12-26 08:13:09 -06:00
Remove some fmt.Println
This commit is contained in:
parent
4506b50828
commit
e91d71ebca
3
eduserver/cache/cache.go
vendored
3
eduserver/cache/cache.go
vendored
|
|
@ -161,11 +161,10 @@ func (t *EDUCache) RemoveUser(userID, roomID string) int64 {
|
||||||
return t.latestSyncPosition
|
return t.latestSyncPosition
|
||||||
}
|
}
|
||||||
|
|
||||||
t.latestSyncPosition++
|
|
||||||
|
|
||||||
timer.Stop()
|
timer.Stop()
|
||||||
delete(roomData.userSet, userID)
|
delete(roomData.userSet, userID)
|
||||||
|
|
||||||
|
t.latestSyncPosition++
|
||||||
t.data[roomID].syncPosition = t.latestSyncPosition
|
t.data[roomID].syncPosition = t.latestSyncPosition
|
||||||
|
|
||||||
return t.latestSyncPosition
|
return t.latestSyncPosition
|
||||||
|
|
|
||||||
|
|
@ -16,7 +16,6 @@ package consumers
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
|
||||||
|
|
||||||
"github.com/Shopify/sarama"
|
"github.com/Shopify/sarama"
|
||||||
"github.com/matrix-org/dendrite/eduserver/api"
|
"github.com/matrix-org/dendrite/eduserver/api"
|
||||||
|
|
@ -98,9 +97,7 @@ func (s *OutputTypingEventConsumer) onMessage(msg *sarama.ConsumerMessage) error
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
fmt.Println("Advancing typing position to", typingPos)
|
|
||||||
s.streams.TypingStreamProvider.Advance(typingPos)
|
s.streams.TypingStreamProvider.Advance(typingPos)
|
||||||
fmt.Println("Advanced typing position to", typingPos)
|
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue