function Rx.start(q)return function(K)assert(Observable.isObservable(K),"\066\097\100 \111\098\115\101\114\118\097\098\108\101")return Observable.new(function(k)k:Fire(q())return K:Subscribe(k:GetFireFailComplete())end)end end

function Rx.start(callback)
	return function(source)
		assert(Observable.isObservable(source), "Bad observable")

		return Observable.new(function(sub)
			sub:Fire(callback())

			return source:Subscribe(sub:GetFireFailComplete())
		end)
	end
end
