(opts ...Option)
| 107 | } |
| 108 | |
| 109 | func parseOptions(opts ...Option) Option { |
| 110 | o := new(funcOption) |
| 111 | for _, opt := range opts { |
| 112 | opt.apply(o) |
| 113 | } |
| 114 | return o |
| 115 | } |
| 116 | |
| 117 | // WithBufferedChannel allows to configure the capacity of a buffered channel. |
| 118 | func WithBufferedChannel(capacity int) Option { |
no test coverage detected