From eeaf7d9f21f8a12d1f87b6e7441e491c688b3810 Mon Sep 17 00:00:00 2001 From: Samuel Williams Date: Mon, 12 Dec 2022 00:24:53 +1300 Subject: [PATCH] I'm not sure what I was planning to do with this. --- lib/async/http/server.rb | 6 +++--- spec/async/http/server_spec.rb | 36 ++++++++++++++++++++++++++++++++++ 2 files changed, 39 insertions(+), 3 deletions(-) create mode 100644 spec/async/http/server_spec.rb diff --git a/lib/async/http/server.rb b/lib/async/http/server.rb index 33e9a5b4..bc36ff73 100755 --- a/lib/async/http/server.rb +++ b/lib/async/http/server.rb @@ -48,7 +48,7 @@ def initialize(app, endpoint, protocol: endpoint.protocol, scheme: endpoint.sche attr :protocol attr :scheme - def accept(peer, address, task: Task.current) + def accept(peer, address) connection = @protocol.server(peer) Console.logger.debug(self) {"Incoming connnection from #{address.inspect} to #{@protocol}"} @@ -70,8 +70,8 @@ def accept(peer, address, task: Task.current) connection&.close end - def run - @endpoint.accept(&self.method(:accept)) + def run(**options) + @endpoint.accept(**options, &self.method(:accept)) end Traces::Provider(self) do diff --git a/spec/async/http/server_spec.rb b/spec/async/http/server_spec.rb new file mode 100644 index 00000000..62a7cccf --- /dev/null +++ b/spec/async/http/server_spec.rb @@ -0,0 +1,36 @@ +# Copyright, 2020, by Samuel G. D. Williams. +# +# Permission is hereby granted, free of charge, to any person obtaining a copy +# of this software and associated documentation files (the "Software"), to deal +# in the Software without restriction, including without limitation the rights +# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +# copies of the Software, and to permit persons to whom the Software is +# furnished to do so, subject to the following conditions: +# +# The above copyright notice and this permission notice shall be included in +# all copies or substantial portions of the Software. +# +# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +# THE SOFTWARE. + +require_relative 'server_context' + +RSpec.describe Async::HTTP::Server do + include_context Async::HTTP::Server + + let(:server) do + Async::HTTP::Server.for(@bound_endpoint) do |request| + Async::Task.current.sleep(delay) + Protocol::HTTP::Response[200, {}, []] + end + end + + it 'can bind to one or more sockets' do + pp barrier + end +end