WIP

Author: ioquatix

config/sus.rb

@@ -5,3 +5,6 @@
 
 require "covered/sus"
 include Covered::Sus
+
+require "async/safe"
+Async::Safe.enable!

gems.rb

@@ -32,4 +32,6 @@
 
 	gem "bake-test"
 	gem "bake-test-external"
+	
+	gem "async-safe"
 end

lib/protocol/http/accept_encoding.rb

@@ -25,7 +25,7 @@ class AcceptEncoding < Middleware
 
 				# There is no point including this:
 				# 'identity' => ->(body){body},
-			}
+			}.freeze
 
 			# Initialize the middleware with the given delegate and wrappers.
 			#

lib/protocol/http/body/buffered.rb

@@ -12,6 +12,8 @@ module HTTP
 		module Body
 			# A body which buffers all its contents.
 			class Buffered < Readable
+				ASYNC_SAFE = {initialize: true}.freeze
+				
 				# Tries to wrap an object in a {Buffered} instance.
 				#
 				# For compatibility, also accepts anything that behaves like an `Array(String)`.

lib/protocol/http/body/stream.rb

@@ -12,6 +12,8 @@ module HTTP
 		module Body
 			# The input stream is an IO-like object which contains the raw HTTP POST data. When applicable, its external encoding must be “ASCII-8BIT” and it must be opened in binary mode, for Ruby 1.9 compatibility. The input stream must respond to gets, each, read and rewind.
 			class Stream
+				ASYNC_SAFE = {initialize: true}.freeze
+				
 				# The default line separator, used by {gets}.
 				NEWLINE = "\n"
 

lib/protocol/http/body/writable.rb

@@ -10,6 +10,8 @@ module HTTP
 		module Body
 			# A dynamic body which you can write to and read from.
 			class Writable < Readable
+				ASYNC_SAFE = true
+				
 				# An error indicating that the body has been closed and no further writes are allowed.
 				class Closed < StandardError
 				end