We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5737a58 commit e316bb3Copy full SHA for e316bb3
pkg/inmemorychannel/event_dispatcher.go
@@ -69,10 +69,13 @@ func (d *InMemoryEventDispatcher) WaitReady() {
69
70
func NewEventDispatcher(args *InMemoryEventDispatcherArgs) *InMemoryEventDispatcher {
71
readTimeout := args.ReadTimeout
72
+ const DefaultReadTimeout = 30 * time.Second
73
+
74
if readTimeout <= 0 {
- readTimeout = 30 * time.Second
75
+ readTimeout = DefaultReadTimeout
76
}
77
78
79
bindingsReceiver := kncloudevents.NewHTTPEventReceiver(
80
args.Port,
81
append(args.HTTPEventReceiverOptions,
0 commit comments