function Rx.mapTo(...)local h=table.pack(...)return function(F)assert(Observable.isObservable(F),"\066\097\100 \111\098\115\101\114\118\097\098\108\101")return Observable.new(function(m)return F:Subscribe(function()m:Fire(table.unpack(h,1,h.n))end,m:GetFailComplete())end)end end

function Rx.mapTo(...)
	local args = table.pack(...)
	return function(source)
		assert(Observable.isObservable(source), "Bad observable")

		return Observable.new(function(sub)
			return source:Subscribe(function()
				sub:Fire(table.unpack(args, 1, args.n))
			end, sub:GetFailComplete())
		end)
	end
end
