Rely on implicit return statements

lib/async/container/best.rb

@@ -33,9 +33,9 @@ def self.fork?
 
 		def self.best_container_class
 			if fork?
-				return Forked
+				Forked
 			else
-				return Threaded
+				Threaded
 			end
 		end
 

lib/async/container/channel.rb

@@ -48,9 +48,9 @@ def close
 			def receive
 				if data = @in.gets
 					begin
-						return JSON.parse(data, symbolize_names: true)
+						JSON.parse(data, symbolize_names: true)
 					rescue
-						return {line: data}
+						{line: data}
 					end
 				end
 			end

lib/async/container/generic.rb

@@ -160,7 +160,7 @@ def spawn(name: nil, restart: false, key: nil, &block)
 				# 	Async.logger.error(self) {$!} if $!
 				end.resume
 
-				return true
+				true
 			end
 
 			def async(**options, &block)
@@ -174,7 +174,7 @@ def run(count: Container.processor_count, **options, &block)
 					spawn(**options, &block)
 				end
 
-				return self
+				self
 			end
 
 			def reload
@@ -188,7 +188,7 @@ def reload
 					value.stop? && (dirty = true)
 				end
 
-				return dirty
+				dirty
 			end
 
 			def mark?(key)
@@ -200,7 +200,7 @@ def mark?(key)
 					end
 				end
 
-				return false
+				false
 			end
 
 			def key?(key)
@@ -221,7 +221,7 @@ def insert(key, child)
 
 				@state[child] = state
 
-				return state
+				state
 			end
 
 			# Clear the child (value) as running.

lib/async/container/hybrid.rb

@@ -42,7 +42,7 @@ def run(count: nil, forks: nil, threads: nil, **options, &block)
 					end
 				end
 
-				return self
+				self
 			end
 		end
 	end

lib/async/container/keyed.rb

@@ -47,7 +47,7 @@ def clear!
 			def stop?
 				unless @marked
 					@value.stop
-					return true
+					true
 				end
 			end
 		end

lib/async/container/notify/pipe.rb

@@ -108,7 +108,7 @@ def environment_for(arguments)
 						arguments.unshift(environment = Hash.new)
 					end
 
-					return environment
+					environment
 				end
 			end
 		end

lib/async/container/notify/server.rb

@@ -52,7 +52,7 @@ def self.load(message)
 						next [key.downcase.to_sym, value]
 					end
 
-					return Hash[pairs]
+					Hash[pairs]
 				end
 
 				def self.generate_path

lib/async/container/notify/socket.rb

@@ -59,7 +59,7 @@ def dump(message)
 						buffer << "#{key.to_s.upcase}=#{value}\n"
 					end
 
-					return buffer
+					buffer
 				end
 
 				def send(**message)

lib/async/container/process.rb

@@ -37,7 +37,7 @@ def self.for(process)
 
 					instance.name = process.name
 
-					return instance
+					instance
 				end
 
 				def initialize(io)
@@ -156,7 +156,7 @@ def wait
 					end
 				end
 
-				return @status
+				@status
 			end
 		end
 	end

lib/async/container/thread.rb

@@ -44,9 +44,7 @@ def error
 
 			class Instance < Notify::Pipe
 				def self.for(thread)
-					instance = self.new(thread.out)
-
-					return instance
+					self.new(thread.out)
 				end
 
 				def initialize(io)
@@ -148,7 +146,7 @@ def wait
 					@waiter = nil
 				end
 
-				return @status
+				@status
 			end
 
 			class Status