diff --git a/telegoutil/api.go b/telegoutil/api.go index df734bb..8d50535 100644 --- a/telegoutil/api.go +++ b/telegoutil/api.go @@ -32,8 +32,8 @@ func NameReader(reader io.Reader, name string) ta.NamedReader { // UpdateProcessor allows you to process updates and still use updates chan. New updates chan will be closed when // original chan is closed. // Note: telego.Update contains pointers so by modifying update you may modify original update. -func UpdateProcessor(updates <-chan telego.Update, buffer uint, - processor func(update telego.Update) telego.Update) <-chan telego.Update { +func UpdateProcessor(updates <-chan telego.Update, buffer uint, processor func(update telego.Update) telego.Update, +) <-chan telego.Update { processedUpdates := make(chan telego.Update, buffer) go func() {