lib/async/http/protocol/http10.rb in async-http-0.48.2 vs lib/async/http/protocol/http10.rb in async-http-0.49.0

@@ -28,15 +28,19 @@
 				
 				def self.bidirectional?
 					false
 				end
 				
-				def self.client(stream)
-					HTTP1::Client.new(stream, VERSION)
+				def self.client(peer)
+					stream = IO::Stream.new(peer, sync: false)
+					
+					return HTTP1::Client.new(stream, VERSION)
 				end
 				
-				def self.server(stream)
-					HTTP1::Server.new(stream, VERSION)
+				def self.server(peer)
+					stream = IO::Stream.new(peer, sync: false)
+					
+					return HTTP1::Server.new(stream, VERSION)
 				end
 				
 				def self.names
 					["http/1.0"]
 				end