function Rx.fromSignal(D)return Observable.new(function(m)return D:Connect(function(...)m:Fire(...)end)end)end

function Rx.fromSignal(event)
	return Observable.new(function(sub)
		-- This stream never completes or fails!
		return event:Connect(function(...)
			sub:Fire(...)
		end)
	end)
end
