Async::HTTP::Body::Writable is moved to Protocol::HTTP::Body::Writable.

Author: ioquatix

async-http.gemspec

@@ -28,7 +28,7 @@ Gem::Specification.new do |spec|
 	spec.add_dependency "async-pool", "~> 0.7"
 	spec.add_dependency "io-endpoint", "~> 0.11"
 	spec.add_dependency "io-stream", "~> 0.4"
-	spec.add_dependency "protocol-http", "~> 0.30"
+	spec.add_dependency "protocol-http", "~> 0.33"
 	spec.add_dependency "protocol-http1", "~> 0.20"
 	spec.add_dependency "protocol-http2", "~> 0.18"
 	spec.add_dependency "traces", ">= 0.10"

lib/async/http/body/writable.rb

@@ -3,104 +3,13 @@
 # Released under the MIT License.
 # Copyright, 2018-2023, by Samuel Williams.
 
-require 'protocol/http/body/readable'
+require 'protocol/http/body/writable'
 require 'async/queue'
 
 module Async
 	module HTTP
 		module Body
-			include ::Protocol::HTTP::Body
-			
-			# A dynamic body which you can write to and read from.
-			class Writable < Readable
-				class Closed < StandardError
-				end
-				
-				# @param [Integer] length The length of the response body if known.
-				# @param [Async::Queue] queue Specify a different queue implementation, e.g. `Async::LimitedQueue.new(8)` to enable back-pressure streaming.
-				def initialize(length = nil, queue: Async::Queue.new)
-					@queue = queue
-					
-					@length = length
-					
-					@count = 0
-					
-					@finished = false
-					
-					@closed = false
-					@error = nil
-				end
-				
-				def length
-					@length
-				end
-				
-				# Stop generating output; cause the next call to write to fail with the given error.
-				def close(error = nil)
-					unless @closed
-						@queue.enqueue(nil)
-						
-						@closed = true
-						@error = error
-					end
-					
-					super
-				end
-				
-				def closed?
-					@closed
-				end
-				
-				def ready?
-					!@queue.empty?
-				end
-				
-				# Has the producer called #finish and has the reader consumed the nil token?
-				def empty?
-					@finished
-				end
-				
-				# Read the next available chunk.
-				def read
-					return if @finished
-					
-					unless chunk = @queue.dequeue
-						@finished = true
-					end
-					
-					return chunk
-				end
-				
-				# Write a single chunk to the body. Signal completion by calling `#finish`.
-				def write(chunk)
-					# If the reader breaks, the writer will break.
-					# The inverse of this is less obvious (*)
-					if @closed
-						raise(@error || Closed)
-					end
-					
-					@count += 1
-					@queue.enqueue(chunk)
-				end
-				
-				alias << write
-				
-				def inspect
-					"\#<#{self.class} #{@count} chunks written, #{status}>"
-				end
-				
-				private
-				
-				def status
-					if @finished
-						'finished'
-					elsif @closed
-						'closing'
-					else
-						'waiting'
-					end
-				end
-			end
+			Writable = ::Protocol::HTTP::Body::Writable
 		end
 	end
 end