wire_test.go 832 B

12345678910111213141516171819202122232425262728293031323334353637
  1. package service
  2. import (
  3. "errors"
  4. "testing"
  5. "time"
  6. "github.com/zeromicro/go-zero/core/collection"
  7. )
  8. func TestProvideTimingWheelService_ReturnsError(t *testing.T) {
  9. original := newTimingWheel
  10. t.Cleanup(func() { newTimingWheel = original })
  11. newTimingWheel = func(_ time.Duration, _ int, _ collection.Execute) (*collection.TimingWheel, error) {
  12. return nil, errors.New("boom")
  13. }
  14. svc, err := ProvideTimingWheelService()
  15. if err == nil {
  16. t.Fatalf("期望返回 error,但得到 nil")
  17. }
  18. if svc != nil {
  19. t.Fatalf("期望返回 nil svc,但得到非空")
  20. }
  21. }
  22. func TestProvideTimingWheelService_Success(t *testing.T) {
  23. svc, err := ProvideTimingWheelService()
  24. if err != nil {
  25. t.Fatalf("期望 err 为 nil,但得到: %v", err)
  26. }
  27. if svc == nil {
  28. t.Fatalf("期望 svc 非空,但得到 nil")
  29. }
  30. svc.Stop()
  31. }