Added primitive and pipeline constructions.

include/ebb_pipe.hrl

@@ -0,0 +1,5 @@
+-record(pipe, {ops}).
+
+-record(feed, {task, op}).
+
+-record(sequence, {tasks}).

include/ebb_prim.hrl

@@ -0,0 +1,7 @@
+-record(thunk, {code}).
+
+-record(func, {code}).
+
+-record(dynamic, {code}).
+
+-record(return, {val}).

src/ebb_pipe.erl

@@ -0,0 +1,22 @@
+-module(ebb_pipe).
+-include("../include/ebb_prim.hrl").
+-include("../include/ebb_pipe.hrl").
+-export([pipe/2, pipe/1, bind/2, feed/2, sequence/2, sequence/1]).
+
+pipe(Op1, Op2) ->
+    #pipe{ops=[Op1, Op2]}.
+
+pipe(Ops) ->
+    #pipe{ops=Ops}.
+
+bind(Task, FuncT) ->
+    feed(Task, #dynamic{code=FuncT}).
+
+feed(Task, Op) ->
+    #feed{task=Task, op=Op}.
+
+sequence(Task1, Task2) ->
+    #sequence{tasks=[Task1, Task2]}.
+
+sequence(Tasks) ->
+    #sequence{tasks=Tasks}.

src/ebb_prim.erl

@@ -0,0 +1,33 @@
+-module(ebb_prim).
+-include("../include/ebb_prim.hrl").
+-include("../include/ebb_pipe.hrl").
+-export([task/2, task/1, return/1,
+	 func/1, app/2, dynamic/1,
+	 ignore/1, nop/0, id/0]).
+
+task(Func, Arg) ->
+    apply(func(Func), Arg).
+
+task(Thunk) ->
+    #thunk{code=Thunk}.
+
+return(Val) ->
+    #return{val=Val}.
+
+func(Func) ->
+    #func{code=Func}.
+
+app(Op, Arg) ->
+    #feed{task=return(Arg), op=Op}.
+
+dynamic(FuncT) ->
+    #dynamic{code=FuncT}.
+
+ignore(Task) ->
+    dynamic(fun(_) -> Task end).
+
+nop() ->
+    #return{val='nop'}.
+
+id() ->
+    #pipe{ops=[]}.