WIP queue

Author: ioquatix

examples/streaming/bidirectional.rb

@@ -22,7 +22,9 @@
 			while chunk = stream.readpartial(1024)
 				$stderr.puts "Server chunk: #{chunk.inspect}"
 				stream.write(chunk)
+				$stderr.puts "Server waiting for next chunk..."
 			end
+			$stderr.puts "Server done reading request."
 		rescue EOFError
 			$stderr.puts "Server EOF."
 			# Ignore EOF errors.
@@ -56,7 +58,7 @@
 		$stderr.puts "Client EOF."
 		# Ignore EOF errors.
 	ensure
-		$stderr.puts "Client closing stream."
+		$stderr.puts "Client closing stream: #{$!}"
 		stream.close
 	end
 

examples/streaming/gems.locked

@@ -1,3 +1,16 @@
+PATH
+  remote: ../../../async-http
+  specs:
+    async-http (0.75.0)
+      async (>= 2.10.2)
+      async-pool (~> 0.7)
+      io-endpoint (~> 0.11)
+      io-stream (~> 0.4)
+      protocol-http (~> 0.33)
+      protocol-http1 (~> 0.20)
+      protocol-http2 (~> 0.18)
+      traces (>= 0.10)
+
 PATH
   remote: ../..
   specs:
@@ -10,15 +23,6 @@ GEM
       console (~> 1.26)
       fiber-annotation
       io-event (~> 1.6, >= 1.6.5)
-    async-http (0.75.0)
-      async (>= 2.10.2)
-      async-pool (~> 0.7)
-      io-endpoint (~> 0.11)
-      io-stream (~> 0.4)
-      protocol-http (~> 0.30)
-      protocol-http1 (~> 0.20)
-      protocol-http2 (~> 0.18)
-      traces (>= 0.10)
     async-pool (0.8.1)
       async (>= 1.25)
       metrics
@@ -64,7 +68,7 @@ PLATFORMS
 
 DEPENDENCIES
   async
-  async-http
+  async-http!
   debug
   protocol-http!
 

examples/streaming/gems.rb

@@ -6,7 +6,7 @@
 source "https://rubygems.org"
 
 gem "async"
-gem "async-http"
+gem "async-http", path: "../../../async-http"
 gem "protocol-http", path: "../../"
 
 gem "debug"

examples/streaming/simple.rb

@@ -0,0 +1,56 @@
+#!/usr/bin/env ruby
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024, by Samuel Williams.
+
+require 'async'
+require 'async/http/client'
+require 'async/http/server'
+require 'async/http/endpoint'
+
+require 'protocol/http/body/streamable'
+require 'protocol/http/body/writable'
+require 'protocol/http/body/stream'
+
+endpoint = Async::HTTP::Endpoint.parse('http://localhost:3000')
+
+Async do
+	server = Async::HTTP::Server.for(endpoint) do |request|
+		output = Protocol::HTTP::Body::Streamable.response(request) do |stream|
+			$stderr.puts "Server sending text..."
+			stream.write("Hello from server!")
+		rescue EOFError
+			$stderr.puts "Server EOF."
+			# Ignore EOF errors.
+		ensure
+			$stderr.puts "Server closing stream."
+			stream.close
+		end
+		
+		Protocol::HTTP::Response[200, {}, output]
+	end
+	
+	server_task = Async{server.run}
+	
+	client = Async::HTTP::Client.new(endpoint)
+	
+	streamable = Protocol::HTTP::Body::Streamable.request do |stream|
+		while chunk = stream.readpartial(1024)
+			$stderr.puts "Client chunk: #{chunk.inspect}"
+		end
+	rescue EOFError
+		$stderr.puts "Client EOF."
+		# Ignore EOF errors.
+	ensure
+		$stderr.puts "Client closing stream."
+		stream.close
+	end
+	
+	$stderr.puts "Client sending request..."
+	response = client.get("/", body: streamable)
+	$stderr.puts "Client received response and streaming it..."
+	streamable.stream(response.body)
+ensure
+	server_task.stop
+end

gems.rb

@@ -26,4 +26,4 @@
 	gem "bake-test-external"
 end
 
-gem "debug", ">= 1.0.0"
+gem "async-http", path: "../async-http"