Method composeTaskEventObserver

internal/daemon/task_event_bridge_notifier.go:106–139

(
	state *bootState,
	store taskStore,
	reentry taskpkg.EventObserver,
)

}

func (d *Daemon) composeTaskEventObserver(
	state *bootState,
	store taskStore,
	reentry taskpkg.EventObserver,
) (taskpkg.EventObserver, *bridgeTerminalTaskNotificationObserver, *networkTaskStatusObserver) {
	if state == nil {
		return reentry, nil, nil
	}
	bridgeEventObserver := newBridgeTerminalTaskNotificationObserver(
		state.bridges,
		store,
		state.bridges,
		state.bridges,
		state.bridges,
		state.notificationPresets,
		state.logger,
		d.now,
		state.cfg.Task.Orchestration.BridgeNotificationTimeout,
	)
	networkStatusObserver := newNetworkTaskStatusObserver(
		state.network,
		store,
		withNetworkTaskStatusObserverLogger(state.logger),
		withNetworkTaskStatusObserverClock(d.now),
		withNetworkTaskStatusObserverQueueSize(state.cfg.Task.Orchestration.NetworkStatusQueueSize),
		withNetworkTaskStatusObserverTimeout(state.cfg.Task.Orchestration.NetworkStatusTimeout),
	)
	return newTaskEventObserverFanout(
		state.logger,
		reentry,
		bridgeEventObserver,
		networkStatusObserver,
	), bridgeEventObserver, networkStatusObserver
}

func newBridgeTerminalTaskNotificationObserver(
	subscriptions bridgepkg.BridgeTaskSubscriptionStore,