function Rx.of(...)local l=table.pack(...)return Observable.new(function(d)for Z=1,l.n,1 do d:Fire(l[Z])end d:Complete()end)end

function Rx.of(...)
	local args = table.pack(...)

	return Observable.new(function(sub)
		for i=1, args.n do
			sub:Fire(args[i])
		end

		sub:Complete()
	end)
end
