code: func NewSubscriberWrapper() server.SubscriberWrapper {
  	return func(next server.SubscriberFunc) server.SubscriberFunc {
  		return func(ctx context.Context, msg server.Message) (err error) {
  			t := newPublicationTracker(msg, ServerProfile)
  			ctx = t.StartSpanFromContext(ctx)
  			defer func() {
  				t.finishWithError(err, noDebugStack)
  			}()
  
  			err = next(ctx, msg)
  			return
  		}
  	}
  }
docs: // NewSubscriberWrapper returns a Subscriber Wrapper