More coverage for notify server / client.

Author: ioquatix

lib/async/container/notify/server.rb

@@ -25,6 +25,8 @@ def self.load(message)
 							value = false
 						elsif value == "1"
 							value = true
+						elsif key == "errno" and value =~ /\A\-?\d+\z/
+							value = Integer(value)
 						end
 
 						next [key.downcase.to_sym, value]
@@ -74,7 +76,11 @@ def receive
 
 							message = Server.load(data)
 
-							yield message
+							if block_given?
+								yield message
+							else
+								return message
+							end
 						end
 					end
 				end

test/async/container/notify.rb

@@ -13,6 +13,16 @@
 	let(:notify_socket) {server.path}
 	let(:client) {subject::Socket.new(notify_socket)}
 
+	it "can send and receive messages" do
+		context = server.bind
+		
+		client.send(true: true, false: false, hello: "world")
+		
+		message = context.receive
+		
+		expect(message).to be == {true: true, false: false, hello: "world"}
+	end
+	
 	with "#ready!" do
 		it "should send message" do
 			begin
@@ -31,11 +41,42 @@
 					end
 				end
 
-				expect(messages.last).to have_keys(ready: be == true)
+				expect(messages.last).to have_keys(
+					ready: be == true
+				)
 			ensure
 				context&.close
 				Process.wait(pid) if pid
 			end
 		end
 	end
+	
+	with "#stopping!" do
+		it "sends stopping message" do
+			context = server.bind
+			
+			client.stopping!
+			
+			message = context.receive
+			
+			expect(message).to have_keys(
+				stopping: be == true
+			)
+		end
+	end
+	
+	with "#error!" do
+		it "sends error message" do
+			context = server.bind
+			
+			client.error!("Boom!")
+			
+			message = context.receive
+			
+			expect(message).to have_keys(
+				status: be == "Boom!",
+				errno: be == -1,
+			)
+		end
+	end	
 end if Async::Container.fork?