diff --git a/ComputingServices/ComputingServices/Taskhost.d/LinqProvider.vb b/ComputingServices/ComputingServices/Taskhost.d/LinqProvider.vb
index 3d41e00..64f9daa 100644
--- a/ComputingServices/ComputingServices/Taskhost.d/LinqProvider.vb
+++ b/ComputingServices/ComputingServices/Taskhost.d/LinqProvider.vb
@@ -1,3 +1,27 @@
-Public Class LinqProvider
+Imports System.Reflection
+Imports Microsoft.VisualBasic.Net
+Imports Microsoft.VisualBasic.Net.Protocol
+Imports Microsoft.VisualBasic.Net.Protocol.Reflection
+Imports Microsoft.VisualBasic.Serialization
 
-End Class
+Namespace TaskHost
+
+    ''' <summary>
+    ''' 执行得到数据集合然后分独传输数据元素
+    ''' </summary>
+    ''' 
+    <Protocol(GetType(TaskProtocols))>
+    Public Class LinqProvider
+
+        ReadOnly __host As TcpSynchronizationServicesSocket = New TcpSynchronizationServicesSocket(GetFirstAvailablePort)
+
+        Sub New()
+            __host.Responsehandler = AddressOf New ProtocolHandler(Me).HandleRequest
+        End Sub
+
+        <Protocol(TaskProtocols.MoveNext)>
+        Private Function __moveNext(CA As Long, args As RequestStream, remote As System.Net.IPEndPoint) As RequestStream
+
+        End Function
+    End Class
+End Namespace
\ No newline at end of file
diff --git a/ComputingServices/ComputingServices/Taskhost.d/Protocols.vb b/ComputingServices/ComputingServices/Taskhost.d/Protocols.vb
index 592b4e3..b9c1c34 100644
--- a/ComputingServices/ComputingServices/Taskhost.d/Protocols.vb
+++ b/ComputingServices/ComputingServices/Taskhost.d/Protocols.vb
@@ -5,5 +5,12 @@
     ''' </summary>
     Public Module Protocols
 
+        Public Enum TaskProtocols
+
+#Region "LINQ supports"
+            MoveNext
+#End Region
+        End Enum
+
     End Module
 End Namespace
\ No newline at end of file