diff --git a/broadcast/processor.go b/broadcast/processor.go index a0e768c2a850325d6bd63370edac0c572e68ab2f..04b00ba35b2ba84a4a691f77970f74cacb07e50e 100644 --- a/broadcast/processor.go +++ b/broadcast/processor.go @@ -53,7 +53,7 @@ func (p *processor) Process(msg format.Message, return } default: - jww.ERROR.Printf("Unrecognized broadcast method %d", p.method) + jww.FATAL.Panicf("Unrecognized broadcast method %d", p.method) } p.cb(payload, receptionID, round) diff --git a/broadcast/processor_test.go b/broadcast/processor_test.go index 6e0aa8edec9d054dc8c3283fc2689fd7eae71593..ae0df4b4e4cdcec92a9fea7d2bf607c5616ef038 100644 --- a/broadcast/processor_test.go +++ b/broadcast/processor_test.go @@ -37,7 +37,7 @@ func Test_processor_Process(t *testing.T) { RsaPubKey: rsaPrivKey.GetPublic(), } - cbChan := make(chan []byte) + cbChan := make(chan []byte, 1) cb := func(payload []byte, _ receptionID.EphemeralIdentity, _ rounds.Round) { cbChan <- payload }