EventCallback defines a callback function for messages
func(ctx context.Context, event events.Message)
| 8 | |
| 9 | // EventCallback defines a callback function for messages |
| 10 | type EventCallback func(ctx context.Context, event events.Message) |
| 11 | |
| 12 | // streamEvents sends incoming events to the provided channel. |
| 13 | func streamEvents(out chan<- events.Message) EventCallback { |
nothing calls this directly
no outgoing calls
no test coverage detected