0
comment
comment
on 1/29/2012 11:49 PM
Right, no messing about this time, straight to the code.
Construction
This is pretty straight forward and I don’t want to detract from the important bits of this post, the only thing
of note is the cancellationToken which is initialized to a default value using the defaultArg function if the
optional parameter cancellationToken is not supplied. The TDF construct that we to use to perform most of the hard
work is incomingMessages which is a BufferBlock<'Msg>.
1
2
3
4
5
6
7
type DataflowAgent<'Msg>(init[...]