Worker.lua

--!strict

local Worker = {}
Worker.__index = Worker


type Callback = (...any) -> ...any

type self = {
	_ParallelEvent: BindableEvent,
	_SerialEvent: BindableEvent,
	
	_IsHandled: boolean
}

export type Worker = typeof(setmetatable({} :: self, Worker))


function Worker.new(): Worker
	local self = setmetatable({} :: self, Worker)
	
	self._ParallelEvent = Instance.new("BindableEvent")
	self._SerialEvent = Instance.new("BindableEvent")
	
	self._IsHandled = false
	
	return self
end


function Worker:Handle(Callback: Callback): ()
	local self: Worker = self
	
	if not self._IsHandled then
		
		self._IsHandled = true
		
		self._ParallelEvent.Event:ConnectParallel(function(...: any): ()
			self._SerialEvent:Fire(Callback(...))
		end)
		
	end
end


function Worker:DoTask(...: any): ...any
	local self: Worker = self
	
	self._ParallelEvent:Fire(...)
	return self._SerialEvent.Event:Wait()
end


return Worker