소스 검색

fix: install from aws duplex

Yeuoly 10 달 전
부모
커밋
406abdde93
1개의 변경된 파일6개의 추가작업 그리고 1개의 파일을 삭제
  1. 6 1
      internal/core/plugin_manager/serverless/upload.go

+ 6 - 1
internal/core/plugin_manager/serverless/upload.go

@@ -40,7 +40,7 @@ func UploadPlugin(decoder decoder.PluginDecoder) (*stream.Stream[LaunchAWSLambda
 		}
 	} else {
 		// found, return directly
-		response := stream.NewStream[LaunchAWSLambdaFunctionResponse](2)
+		response := stream.NewStream[LaunchAWSLambdaFunctionResponse](3)
 		response.Write(LaunchAWSLambdaFunctionResponse{
 			Event:   LambdaUrl,
 			Message: function.FunctionURL,
@@ -49,6 +49,11 @@ func UploadPlugin(decoder decoder.PluginDecoder) (*stream.Stream[LaunchAWSLambda
 			Event:   Lambda,
 			Message: function.FunctionName,
 		})
+		response.Write(LaunchAWSLambdaFunctionResponse{
+			Event:   Done,
+			Message: "",
+		})
+		response.Close()
 		return response, nil
 	}