diff --git a/destination_middleware.go b/destination_middleware.go index 3b93174..126df9d 100644 --- a/destination_middleware.go +++ b/destination_middleware.go @@ -31,8 +31,6 @@ import ( "golang.org/x/time/rate" ) -var destinationMiddlewareType = reflect.TypeFor[DestinationMiddleware]() - // DestinationMiddleware wraps a Destination and adds functionality to it. type DestinationMiddleware interface { Wrap(Destination) Destination @@ -116,7 +114,6 @@ func destinationMiddlewareFromConfigRecursive(cfgVal reflect.Value) []Destinatio } switch { - case field.Type().Implements(destinationMiddlewareType): // This is a middleware config, store it. //nolint:forcetypeassert // type checked above with field.Type().Implements() @@ -126,7 +123,6 @@ func destinationMiddlewareFromConfigRecursive(cfgVal reflect.Value) []Destinatio cfgType.Field(i).Type.Kind() == reflect.Struct: // This is an embedded struct, dive deeper. mw = append(mw, destinationMiddlewareFromConfigRecursive(field.Elem())...) - } } diff --git a/source_middleware.go b/source_middleware.go index 1b56735..482fd3d 100644 --- a/source_middleware.go +++ b/source_middleware.go @@ -110,7 +110,6 @@ func sourceMiddlewareFromConfigRecursive(cfgVal reflect.Value) []SourceMiddlewar } switch { - case field.Type().Implements(sourceMiddlewareType): // This is a middleware config, store it. //nolint:forcetypeassert // type checked above with field.Type().Implements() @@ -120,7 +119,6 @@ func sourceMiddlewareFromConfigRecursive(cfgVal reflect.Value) []SourceMiddlewar cfgType.Field(i).Type.Kind() == reflect.Struct: // This is an embedded struct, dive deeper. mw = append(mw, sourceMiddlewareFromConfigRecursive(field.Elem())...) - } }