no message

opms_libary/micro_srv/micro_srv.go

@@ -159,13 +159,12 @@ func streamHandler(conn net.Conn, args *share.StreamServiceArgs) {
 		buf = make([]byte, size)
 		conn.Read(buf)
 		tmpFile.Write(buf)
-
+		file := &multipart.MultipartFile{FileName: paramName, FileSize: gconv.Int64(fileSize), File: tmpFile, Meta: args.Meta}
+		_ = append(array, file)
 		// 判断是否结束
 		isEnd := make([]byte, 1)
 		_, err = conn.Read(isEnd)
 		if err != nil || isEnd[0] == '1' {
-			file := &multipart.MultipartFile{FileName: paramName, FileSize: gconv.Int64(fileSize), File: tmpFile, Meta: args.Meta}
-			_ = append(array, file)
 			continue
 		}
 		if isEnd[0] == '2' {