Function TestSequentialHandlerMultipleChannel

sequential_handler_test.go:47–61

Test that in the case of multiple destination channels, one channel being blocked does not prevent the other channel receiving messages.

(t *testing.T)

// Test that in the case of multiple destination channels, one channel
// being blocked does not prevent the other channel receiving messages.
func TestSequentialHandlerMultipleChannel(t *testing.T) {
	t.Parallel()

	handler := NewSequentialSignalHandler()

	channelOne := make(chan *Signal)
	handler.(SignalRegistrar).AddSignal(channelOne)

	channelTwo := make(chan *Signal, 10)
	handler.(SignalRegistrar).AddSignal(channelTwo)

	writeSignals(handler, 1000)

	readSignals(t, channelTwo)
}

// Test that removing one channel results in no more messages being
// written to that channel.