var chainX = BlockGenerator< Tuple<int, System.DateTime, …

Twetch ·

var chainX =
BlockGenerator<
Tuple<int, System.DateTime, string>>.Generate(0x00001111, datadir: "d:\\zillionData");

var chainY =
BlockGenerator<
Tuple<int, System.DateTime, string>>
.Generate(0xfa10, datadir: "d:\\<hash of datatype def>");

var chainXbyY =
from x in chainX
from y in chainY
let z = x.GetData().Item1 * y.GetData().Item1
select z;

chainXbyY.DumpLatest();

chainXbyY.ManySelect(o =>
Qactive.Qbservable2.ServeQbservable(o,
new QactiveTcpProviderFactory()
.Create()).DumpLatest()); // sends blocks to the network

var q =
from tick in Observable.Timer(TimeSpan.FromSeconds(1))
from block in chainXbyY
select block;

q.Dump();