From c1e51592daf6ed4f1f3def7842b176a586cfa70c Mon Sep 17 00:00:00 2001 From: "Pascal S. de Kloe" Date: Thu, 18 Feb 2021 23:07:27 +0100 Subject: [PATCH] Nonfunctional code reorder. --- mqtttest/mqtttest.go | 26 +++++++++++++------------- 1 file changed, 13 insertions(+), 13 deletions(-) diff --git a/mqtttest/mqtttest.go b/mqtttest/mqtttest.go index 7c35b06..19ca241 100644 --- a/mqtttest/mqtttest.go +++ b/mqtttest/mqtttest.go @@ -11,19 +11,6 @@ import ( "github.com/pascaldekloe/mqtt" ) -// NewPublishStub returns a new stub for mqtt.Client Publish with a fixed return -// value. -func NewPublishStub(returnFix error) func(quit <-chan struct{}, message []byte, topic string) error { - return func(quit <-chan struct{}, message []byte, topic string) error { - select { - case <-quit: - return mqtt.ErrCanceled - default: - return returnFix - } - } -} - // Transfer defines a message exchange. type Transfer struct { Message []byte // payload @@ -95,6 +82,19 @@ func NewPublishMock(t testing.TB, want ...Transfer) func(quit <-chan struct{}, m } } +// NewPublishStub returns a new stub for mqtt.Client Publish with a fixed return +// value. +func NewPublishStub(returnFix error) func(quit <-chan struct{}, message []byte, topic string) error { + return func(quit <-chan struct{}, message []byte, topic string) error { + select { + case <-quit: + return mqtt.ErrCanceled + default: + return returnFix + } + } +} + // AckBlock prevents ack <-chan error submission. type AckBlock struct { Delay time.Duration // zero defaults to indefinite