- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for Tubach (0.13 sec)
-
internal/pubsub/pubsub.go
}() // Read from subChT and write to subCh var buf bytes.Buffer enc := json.NewEncoder(&buf) for { select { case <-doneCh: return case v, ok := <-subChT: if !ok { return } buf.Reset() err := enc.Encode(v) if err != nil { return } select { case subCh <- append(GetByteBuffer()[:0], buf.Bytes()...): continue
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 16:57:30 GMT 2024 - 5.2K bytes - Viewed (0)