amplifier

scope(failure) {writefln("Unittest failure :%s(%s)", __FILE__, __LINE__); stdout.flush();}
scope(success) {writefln("Unittest success :%s(%s)", __FILE__, __LINE__); stdout.flush();}

auto arr4 = [0, 1, 2, 3].repeatStream,
     amped = arr4.amplifier(4);

assert(amped.read(new int[4]) == [0, 4, 8, 12]);
static assert(isInplaceComputableStream!(typeof(arr4)));
static assert(isInplaceComputableStream!(typeof(amped), "*"));
static assert(isInplaceComputableStream!(typeof(amped), "/"));

auto arr = [3, 4, 1, 2];
assert(amped.readOp!"*"(arr) == [0, 16, 8, 24]);