diff --git a/基本结构/042 restful/tf-35-app.py b/基本结构/松耦合/restful/tf-35-app.py
similarity index 100%
rename from 基本结构/042 restful/tf-35-app.py
rename to 基本结构/松耦合/restful/tf-35-app.py
diff --git a/基本结构/042 restful/tf-35-request.py b/基本结构/松耦合/restful/tf-35-request.py
similarity index 95%
rename from 基本结构/042 restful/tf-35-request.py
rename to 基本结构/松耦合/restful/tf-35-request.py
index 8fa98c1..d9803a8 100644
--- a/基本结构/042 restful/tf-35-request.py	
+++ b/基本结构/松耦合/restful/tf-35-request.py
@@ -1,45 +1,45 @@
-# -*- coding: utf-8 -*-
-import requests
-from cppy.cp_util import *
-
-# 查询资源，得到空列表
-url = 'http://127.0.0.1:5000//books'
-response = requests.get(url)
-print(response.json())
-time.sleep(2)
-
-# - 创建一个1号资源
-print('创建一个1号资源')
-book_1 = {"id": 1, "title": "Python编程:从入门到实践", "content": testfilepath}
-url = 'http://127.0.0.1:5000/books/1'
-response = requests.put(url,json=book_1)
-time.sleep(2)
-
-# - 创建一个2号资源（修改testfilepaht变量）
-print('创建一个2号资源')
-testfilepath = testfilepath.replace('Prey.txt','Pride-and-Prejudice.txt')
-book_2 = {"id": 2, "title": "深入浅出计算机组成原理", "content": testfilepath}
-url = 'http://127.0.0.1:5000/books/2'
-response = requests.put(url,json=book_2)
-time.sleep(2)
-
-# - 创建一个3号资源（修改testfilepaht变量）正好有3个文件
-print('创建一个3号资源')
-testfilepath = testfilepath.replace('Pride-and-Prejudice.txt','test.txt')
-book_3 = {"id": 3, "title": "算法导论", "content": testfilepath}
-url = 'http://127.0.0.1:5000/books/3'
-response = requests.put(url,json=book_3)
-time.sleep(2)
-
-# - 查询资源，看到结果
-print('查询资源，看到结果')
-url = 'http://127.0.0.1:5000//books'
-response = requests.get(url)
-print(response.json())
-time.sleep(2)
-
-# - 操作1号资源，得到词频
-print('操作1号资源，得到词频')
-url = 'http://127.0.0.1:5000/books/1/word_frequency'
-response = requests.get(url)
+# -*- coding: utf-8 -*-
+import requests
+from cppy.cp_util import *
+
+# 查询资源，得到空列表
+url = 'http://127.0.0.1:5000//books'
+response = requests.get(url)
+print(response.json())
+time.sleep(2)
+
+# - 创建一个1号资源
+print('创建一个1号资源')
+book_1 = {"id": 1, "title": "Python编程:从入门到实践", "content": testfilepath}
+url = 'http://127.0.0.1:5000/books/1'
+response = requests.put(url,json=book_1)
+time.sleep(2)
+
+# - 创建一个2号资源（修改testfilepaht变量）
+print('创建一个2号资源')
+testfilepath = testfilepath.replace('Prey.txt','Pride-and-Prejudice.txt')
+book_2 = {"id": 2, "title": "深入浅出计算机组成原理", "content": testfilepath}
+url = 'http://127.0.0.1:5000/books/2'
+response = requests.put(url,json=book_2)
+time.sleep(2)
+
+# - 创建一个3号资源（修改testfilepaht变量）正好有3个文件
+print('创建一个3号资源')
+testfilepath = testfilepath.replace('Pride-and-Prejudice.txt','test.txt')
+book_3 = {"id": 3, "title": "算法导论", "content": testfilepath}
+url = 'http://127.0.0.1:5000/books/3'
+response = requests.put(url,json=book_3)
+time.sleep(2)
+
+# - 查询资源，看到结果
+print('查询资源，看到结果')
+url = 'http://127.0.0.1:5000//books'
+response = requests.get(url)
+print(response.json())
+time.sleep(2)
+
+# - 操作1号资源，得到词频
+print('操作1号资源，得到词频')
+url = 'http://127.0.0.1:5000/books/1/word_frequency'
+response = requests.get(url)
 print_word_freqs(response.json())
\ No newline at end of file
diff --git a/语言特性/尾调用_类方法/t26c。py b/语言特性/尾调用_类方法/t26c。py
deleted file mode 100644
index 74ae750..0000000
--- a/语言特性/尾调用_类方法/t26c。py
+++ /dev/null
@@ -1,65 +0,0 @@
-from cppy.cp_util import *
-from collections import Counter  
-from heapq import nlargest  
-import re  
-  
-  
-class Pipeline:  
-    def __init__(self):  
-        pass  
-  
-    def __or__(self, other):  
-        class PipelineComposition(Pipeline):  
-            def __init__(self, first, second):  
-                self.first = first  
-                self.second = second  
-  
-            def process(self, data):  
-                return self.second.process(self.first.process(data))  
-  
-        return PipelineComposition(self, other)  
-  
-    def process(self, data):  
-        raise NotImplementedError  
-  
-  
-class FileReader(Pipeline):  
-    def __init__(self, filename):  
-        super().__init__()  
-        self.filename = filename  
-  
-    def process(self):  
-        with open(self.filename, 'r', encoding='utf-8') as file:  
-            content = file.read()  
-        return content  
-  
-  
-class WordFrequencyCounter(Pipeline):  
-    def process(self, text):  
-        words = re.findall(r'\w+', text.lower())  
-        word_freq = Counter(words)  
-        return word_freq  
-  
-  
-class TopNFilter(Pipeline):  
-    def __init__(self, n):  
-        super().__init__()  
-        self.n = n  
-  
-    def process(self, word_freq):  
-        return nlargest(self.n, word_freq.items(), key=lambda item: item[1])  
-  
-  
-# 假设有一个文本文件"text.txt"，其内容是需要分析的文本  
-filename = testfilepath
-n = 5  # 求取最高5个词频  
-  
-# 创建管道  
-pipeline = FileReader(filename) | WordFrequencyCounter() | TopNFilter(n)  
-  
-# 执行管道  
-top_n_words = pipeline.process()  
-  
-# 打印结果  
-for word, freq in top_n_words:  
-    print(f"{word}: {freq}")
\ No newline at end of file
diff --git a/语言特性/尾调用_类方法/tf-26.py b/语言特性/尾调用_类方法/tf-26.py
index d547d50..acb46d0 100644
--- a/语言特性/尾调用_类方法/tf-26.py
+++ b/语言特性/尾调用_类方法/tf-26.py
@@ -1,42 +1,21 @@
-from collections import Counter
 from cppy.cp_util import *
-import re
 
+# 如果有连续的对数据加工操作，而且总是把共同加工数据对象当第一个参数，可以用一个管道框架来封装
+# 注意：最后还要调用一次对象call方法，才能执行最后一个函数
 class Pipe:
-    def __init__(self, func, *args, **kwargs):
-        # print( self, func, *args, **kwargs )
+    def __init__(self, func, *args, **kwargs):        
         self.func = func
         self.args = args
         self.kwargs = kwargs
 
     def __or__(self, other):
-        return Pipe(lambda x: self.func(x) or other.func(x))
-        # print(self.func.__name__, other.func.__name__ )
-        def composed_func():
-            print( other.func(self.func(self.args, self.kwargs), other.args, other.kwargs) ) 
-            return other.func(self.func(self.args, self.kwargs), other.args, other.kwargs)
-        return Pipe(composed_func)
+        data = self.func(*self.args, **self.kwargs)                     
+        return Pipe( other.func,data,*other.args,**other.kwargs)
 
-    # def __call__(self, *args, **kwargs):
-    #     print( *args, **kwargs )
-    #     return self.func(*args, **kwargs)
-    def __call__(self, data):        
-        return self.func(data)    
+    def __call__(self):
+        return self.func(*self.args, **self.kwargs)
 
-def read_file(filename):
-    with open(filename, 'r',encoding='utf-8') as f:
-        return f.read()
 
-def split_words(text):
-    return re.findall(r'\b\w+\b', text.lower())
-
-def count_words(words):
-    return Counter(words)
-
-def top_n_words(word_counts, n):
-    return word_counts.most_common(n)
-
-# 使用管道
-pipe = Pipe(read_file) | Pipe(split_words) | Pipe(count_words) | Pipe(top_n_words, 10)
-result = pipe(testfilepath)
-print(result)
\ No newline at end of file
+# 模仿管道
+pipe = Pipe(extract_file_words,testfilepath) | Pipe(get_frequencies) | Pipe(sort_dict) | Pipe(print_word_freqs, 10)
+pipe()
\ No newline at end of file
diff --git a/语言特性/尾调用_类方法/tf-26B.py b/语言特性/尾调用_类方法/tf-26B.py
index 20c7b3b..0ce8433 100644
--- a/语言特性/尾调用_类方法/tf-26B.py
+++ b/语言特性/尾调用_类方法/tf-26B.py
@@ -1,49 +1,25 @@
-import re
-from collections import Counter
-from functools import reduce
 from cppy.cp_util import *
 
-class Pipeline:
-    def __init__(self, function):
-        self.function = function
-
-    def __or__(self, other):
-        if isinstance(other, Pipeline):
-            return Pipeline(lambda x: self.function(x) or other.function(x))
-        else:
-            raise TypeError("The argument must be an instance of Pipeline")
-
-    def process(self, data):
-        return self.function(data)
-
-# 定义处理函数
-def read_file(path):
-    with open(path, 'r', encoding='utf-8') as file:
-        return file.read()
-
-def clean_text(text):
-    return re.sub(r'[^\w\s]', '', text).lower()
-
-def tokenize(text):
-    return re.findall(r'\b\w+\b', text)
-
-def remove_stop_words(tokens, stop_words):
-    return [token for token in tokens if token not in stop_words]
-
-def count_frequencies(tokens):
-    return Counter(tokens)
-
-def get_top_n_frequencies(counter, n):
-    return counter.most_common(n)
-
-# 定义停用词列表
-stop_words = set(['the', 'and', 'a', 'to', 'of', 'in', 'for', 'on', 'is', 'it', 'with', 'that', 'as', 'by', 'this', 'at', 'be', 'which', 'from', 'or', 'are', 'an', 'but', 'not', 'you', 'have', 'your', 'can', 'will', 'all', 'any', 'if', 'their', 'would', 'what', 'there', 'when', 'which', 'who', 'whom', 'whose', 'where', 'why'])
-
-# 创建管道
-pipeline = (Pipeline(read_file) | clean_text | tokenize
-             | remove_stop_words | count_frequencies
-             | get_top_n_frequencies(n=10))
-
-# 执行管道并打印结果
-top_n_word_frequencies = pipeline.process( testfilepath )
-print(top_n_word_frequencies)
\ No newline at end of file
+# 这种连续方法调用，看起来也比较舒服
+# 每一个类方法返回 self ，另外最后一个方法注意是否有返回值
+
+class Flow:
+    def extract_file_words(self, filepath):
+        self.data = extract_file_words(filepath)
+        return self
+    
+    def get_frequencies(self):
+        self.data = get_frequencies(self.data)
+        return self
+    
+    def sort_dict(self):
+        self.data = sort_dict(self.data)
+        return self        
+
+    def print_word_freqs(self, n):
+        print_word_freqs(self.data, n)
+        return self
+
+
+# 顺序调用
+Flow().extract_file_words(testfilepath).get_frequencies().sort_dict().print_word_freqs(10)