diff --git a/Parallel/BufferBuilder.vb b/Parallel/BufferBuilder.vb
new file mode 100644
index 0000000..1f21d46
--- /dev/null
+++ b/Parallel/BufferBuilder.vb
@@ -0,0 +1,3 @@
+Public Class BufferBuilder
+
+End Class
diff --git a/Parallel/Parallel.vbproj b/Parallel/Parallel.vbproj
index bd5f821..bfd6319 100644
--- a/Parallel/Parallel.vbproj
+++ b/Parallel/Parallel.vbproj
@@ -64,6 +64,7 @@
     <Import Include="System.Threading.Tasks" />
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="BufferBuilder.vb" />
     <Compile Include="Protocols.vb" />
     <Compile Include="IPCSocket.vb" />
     <Compile Include="IDelegate.vb" />
diff --git a/Parallel/SlaveTask.vb b/Parallel/SlaveTask.vb
index bd0602a..ce37890 100644
--- a/Parallel/SlaveTask.vb
+++ b/Parallel/SlaveTask.vb
@@ -1,27 +1,66 @@
 Imports System.IO
+Imports System.Threading
+Imports Microsoft.VisualBasic.CommandLine.InteropService
 Imports Microsoft.VisualBasic.MIME.application.json
 Imports Microsoft.VisualBasic.MIME.application.json.BSON
-Imports Microsoft.VisualBasic.Scripting.MetaData
+
+Public Delegate Function ISlaveTask(processor As InteropService, port As Integer) As String
 
 Public Class SlaveTask
 
+    ReadOnly toBuffers As New Dictionary(Of Type, Func(Of Object, Stream))
+    ReadOnly fromBuffer As New Dictionary(Of Type, Func(Of Stream, Object))
+    ReadOnly processor As InteropService
+    ReadOnly builder As ISlaveTask
+
+    Sub New(processor As InteropService, cli As ISlaveTask)
+        Me.builder = cli
+        Me.processor = processor
+    End Sub
+
+    Public Function Emit(Of T)(streamAs As Func(Of T, Stream)) As SlaveTask
+        toBuffers(GetType(T)) = Function(obj) streamAs(obj)
+        Return Me
+    End Function
+
+    Public Function Emit(Of T)(fromStream As Func(Of Stream, T)) As SlaveTask
+        fromBuffer(GetType(T)) = Function(buf) fromStream(buf)
+        Return Me
+    End Function
+
+    Private Function handlePOST(buf As Stream, type As Type) As Object
+        If fromBuffer.ContainsKey(type) Then
+            Return fromBuffer(type)(buf)
+        Else
+            Return BSONFormat.Load(buf).CreateObject(type)
+        End If
+    End Function
+
+    Private Function handleGET(param As Object) As Stream
+        Dim type As Type = param.GetType
+
+        If toBuffers.ContainsKey(type) Then
+            Return toBuffers(type)(param)
+        Else
+            Dim element = type.GetJsonElement(param, New JSONSerializerOptions)
+            Dim buf As Stream = BSONFormat.GetBuffer(element)
+
+            Return buf
+        End If
+    End Function
+
     Public Function RunTask(entry As [Delegate], ParamArray parameters As Object()) As Object
         Dim target As New IDelegate(entry)
         Dim result As Object = Nothing
         Dim host As New IPCSocket With {
-            .handlePOSTResult = Sub(buf)
-                                    result = BSONFormat.Load(buf).CreateObject(entry.Method.ReturnType)
-                                End Sub,
+            .handlePOSTResult = Sub(buf) result = handlePOST(buf, entry.Method.ReturnType),
             .nargs = parameters.Length,
-            .handleGetArgument = Function(i)
-                                     Dim type As Type = parameters(i).GetType
-                                     Dim element = type.GetJsonElement(parameters(i), New JSONSerializerOptions)
-
-                                     Return BSONFormat.GetBuffer(element)
-                                 End Function
+            .handleGetArgument = Function(i) handleGET(parameters(i))
         }
 
-        Call host.Run()
+        Call New Thread(AddressOf host.Run).Start()
+        Call Thread.Sleep(100)
+        Call CommandLine.Call(processor, builder(processor, host.HostPort))
 
         Return result
     End Function