diff --git a/pkg/inmemorychannel/event_dispatcher.go b/pkg/inmemorychannel/event_dispatcher.go index 4f53c0ea7c0..029c7a14a4a 100644 --- a/pkg/inmemorychannel/event_dispatcher.go +++ b/pkg/inmemorychannel/event_dispatcher.go @@ -68,10 +68,13 @@ func (d *InMemoryEventDispatcher) WaitReady() { } func NewEventDispatcher(args *InMemoryEventDispatcherArgs) *InMemoryEventDispatcher { - // TODO set read timeouts? bindingsReceiver := kncloudevents.NewHTTPEventReceiver( args.Port, - args.HTTPEventReceiverOptions..., + append( + []kncloudevents.HTTPEventReceiverOption{ + kncloudevents.WithReadTimeout(args.ReadTimeout), + }, + args.HTTPEventReceiverOptions...)..., ) dispatcher := &InMemoryEventDispatcher{