@@ -0,0 +1,580 @@
+package pw.koj.jetstreem.core;%0A%0Apublic class StrmFuncMap extends Streem %7B%0A    private StrmMapFunc mapFunc;%0A%0A    public StrmFuncMap(StrmQueue queue, StrmMapFunc func) %7B%0A        super(TaskMode.FILT, queue, StrmFuncMap::mapRecv, null, null);%0A        this.mapFunc = func;%0A    %7D%0A%0A    private StrmMapFunc mapFunc() %7B%0A        return this.mapFunc;%0A    %7D%0A%0A    private static void mapRecv(Streem strm, Void data) %7B%0A        StrmFuncMap fmap = (StrmFuncMap)strm;%0A        StrmMapFunc func = fmap.mapFunc();%0A        %0A        Void d = func.call(strm, data);%0A        strm.emit(d, null);%0A    %7D%0A%7D%0A%0A

add class StrmFuncMap