yjp 2 yıl önce
ebeveyn
işleme
ef11f6525d
2 değiştirilmiş dosya ile 0 ekleme ve 2 silme
  1. 0 1
      mqtt_binding/mqtt_binding.go
  2. 0 1
      mqtt_binding_test.go

+ 0 - 1
mqtt_binding/mqtt_binding.go

@@ -36,7 +36,6 @@ func Bind[I any, O any](b *Binding, item *BindItem[I, O], handlers ...router.Han
 type BindItem[I any, O any] struct {
 	Topic               string               // 请求路径
 	Qos                 byte                 // QOS
-	Retained            bool                 // 是否保留响应
 	ResponseFunc        response.SendFunc[O] // 响应泛型函数
 	BusinessFunc        BusinessFunc[I, O]   // 业务泛型函数
 	OptionalBindingFunc BindingFunc[O]       // 可选的绑定函数

+ 0 - 1
mqtt_binding_test.go

@@ -37,7 +37,6 @@ func TestMqttBinding(t *testing.T) {
 	}, map[string]interface{}]{
 		Topic:        "/test-topic",
 		Qos:          2,
-		Retained:     true,
 		ResponseFunc: response.SendMapResponse,
 		BusinessFunc: func(c *mqtt_client.MqttClient, inputModel struct {
 			Time string `json:"time"`