Skip to content

Commit b2a7a64

Browse files
committed
Add more support for **options.
1 parent 55c2c2d commit b2a7a64

File tree

4 files changed

+14
-14
lines changed

4 files changed

+14
-14
lines changed

lib/async/http/protocol/http1.rb

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,16 +23,16 @@ def self.trailer?
2323
true
2424
end
2525

26-
def self.client(peer)
26+
def self.client(peer, **options)
2727
stream = ::IO::Stream(peer)
2828

29-
return HTTP1::Client.new(stream, VERSION)
29+
return HTTP1::Client.new(stream, VERSION, **options)
3030
end
3131

32-
def self.server(peer)
32+
def self.server(peer, **options)
3333
stream = ::IO::Stream(peer)
3434

35-
return HTTP1::Server.new(stream, VERSION)
35+
return HTTP1::Server.new(stream, VERSION, **options)
3636
end
3737

3838
def self.names

lib/async/http/protocol/http10.rb

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,16 +20,16 @@ def self.trailer?
2020
false
2121
end
2222

23-
def self.client(peer)
23+
def self.client(peer, **options)
2424
stream = ::IO::Stream(peer)
2525

26-
return HTTP1::Client.new(stream, VERSION)
26+
return HTTP1::Client.new(stream, VERSION, **options)
2727
end
2828

29-
def self.server(peer)
29+
def self.server(peer, **options)
3030
stream = ::IO::Stream(peer)
3131

32-
return HTTP1::Server.new(stream, VERSION)
32+
return HTTP1::Server.new(stream, VERSION, **options)
3333
end
3434

3535
def self.names

lib/async/http/protocol/http11.rb

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,16 +21,16 @@ def self.trailer?
2121
true
2222
end
2323

24-
def self.client(peer)
24+
def self.client(peer, **options)
2525
stream = ::IO::Stream(peer)
2626

27-
return HTTP1::Client.new(stream, VERSION)
27+
return HTTP1::Client.new(stream, VERSION, **options)
2828
end
2929

30-
def self.server(peer)
30+
def self.server(peer, **options)
3131
stream = ::IO::Stream(peer)
3232

33-
return HTTP1::Server.new(stream, VERSION)
33+
return HTTP1::Server.new(stream, VERSION, **options)
3434
end
3535

3636
def self.names

lib/async/http/protocol/http2.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ def self.trailer?
3939
::Protocol::HTTP2::Settings::NO_RFC7540_PRIORITIES => 1,
4040
}
4141

42-
def self.client(peer, settings = CLIENT_SETTINGS)
42+
def self.client(peer, settings: CLIENT_SETTINGS)
4343
stream = ::IO::Stream(peer)
4444
client = Client.new(stream)
4545

@@ -49,7 +49,7 @@ def self.client(peer, settings = CLIENT_SETTINGS)
4949
return client
5050
end
5151

52-
def self.server(peer, settings = SERVER_SETTINGS)
52+
def self.server(peer, settings: SERVER_SETTINGS)
5353
stream = ::IO::Stream(peer)
5454
server = Server.new(stream)
5555

0 commit comments

Comments
 (0)