Run flows immediately when started

Fixes #14

game.project

@@ -1,7 +1,8 @@
 [project]
 title = Ludobits
 version = 0.7.6
-dependencies = https://github.com/britzl/deftest/archive/2.7.0.zip,https://github.com/britzl/defold-input/archive/1.3.0.zip
+dependencies#0 = https://github.com/britzl/deftest/archive/2.7.0.zip
+dependencies#1 = https://github.com/britzl/defold-input/archive/1.3.0.zip
 
 [bootstrap]
 main_collection = /examples/examples.collectionc

ludobits/m/flow.lua

@@ -142,20 +142,19 @@ end
 -- @return The created flow instance
 function M.start(fn, options, on_error)
 	assert(fn, "You must provide a function")
+	local created_instance = create_or_get(coroutine.create(fn))
+	created_instance.on_error = on_error
+
+	local parallel = options and options.parallel
 	local co = coroutine.running()
-	if not co or not instances[co] or (options and options.parallel) then
-		local created_instance = create_or_get(coroutine.create(fn))
-		created_instance.on_error = on_error
-		return created_instance
-	else
-		local running_instance = instances[co]
-		local created_instance = create_or_get(coroutine.create(fn))
-		created_instance.on_error = on_error
+	if co and instances[co] and not parallel then
 		M.until_true(function()
 			return instances[created_instance.co] == nil
 		end)
-		return created_instance
-	end
+	else
+		update_flow(self, 0, created_instance.co)
+	end 
+	return created_instance
 end
 
 

test/test_flow.lua

@@ -47,12 +47,12 @@ return function()
 			assert(instance)
 		end)
 
-		it("should not run the flow immediately when started", function()
+		it("should run the flow immediately when started", function()
 			local flow_finished = false
 			flow.start(function()
 				flow_finished = true
 			end)
-			assert(not flow_finished)
+			assert(flow_finished)
 		end)
 
 		it("should run the flow on a timer", function()