aykhans/bsky-feedgen
1
0
Fork 0
mirror of https://github.com/aykhans/bsky-feedgen.git synced 2025-07-17 21:34:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update 'azInvalidUser' list

Browse Source
This commit is contained in:
Aykhan Shahsuvarov
2025-05-21 16:43:39 +04:00
parent c4bd6affa6
commit 7242754124
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/consumer/base.go
View File

@@ -272,7 +272,7 @@ func ConsumeAndSaveToMongoDB(
postBatch = []*collections.Post{} // Clear batch after insert
} else {
// If we haven't seen any data for 25 seconds, cancel the consumer connection
if consumerLastFlushingTime.Add(time.Second*25).Before(time.Now()) {
if consumerLastFlushingTime.Add(time.Second * 25).Before(time.Now()) {
cancel()
}
}