AssertCalledHandlerFunc returns a new HandlerFunc based on a given one that will make the test fail if the given handler has not been called at least `times` before a given timeout.

NewRouter creates a watermillmessage.Router with some needed test cleanup actions.

NewRouterWithLogs creates a watermillmessage.Router with some needed test cleanup actions.

ReliablePublisher creates a publisher with a subscriber that will make the test fail if the number of published messages does not reach `messagesToAssert` before a given timeout.

NoopPublisher is a publisher that publishes nothing.