Expose Process#spawn.

Author: ioquatix

lib/async/container/notify/server.rb

@@ -11,7 +11,6 @@ module Async
 	module Container
 		module Notify
 			class Server
-				NOTIFY_SOCKET = "NOTIFY_SOCKET"
 				MAXIMUM_MESSAGE_SIZE = 4096
 
 				def self.load(message)

lib/async/container/process.rb

@@ -84,15 +84,13 @@ def self.fork(**options)
 				end
 			end
 
-			# def self.spawn(*arguments, name: nil, **options)
-			# 	self.new(name: name) do |process|
-			# 		unless options.key?(:out)
-			# 			options[:out] = process.out
-			# 		end
-			# 
-			# 		::Process.spawn(*arguments, **options)
-			# 	end
-			# end
+			def self.spawn(*arguments, name: nil, **options)
+				self.new(name: name) do |process|
+					Notify::Pipe.new(process.out).before_spawn(arguments, options)
+					
+					::Process.spawn(*arguments, **options)
+				end
+			end
 
 			# Initialize the process.
 			# @parameter name [String] The name to use for the child process.
@@ -122,6 +120,9 @@ def name= value
 			# @attribute [String]
 			attr :name
 
+			# @attribute [Integer] The process identifier.
+			attr :pid
+			
 			# A human readable representation of the process.
 			# @returns [String]
 			def inspect