Experimental Stream Fusion library on core.async channels