Missed async-io in a few places...

examples/fan-out/pipe.rb

@@ -2,8 +2,7 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2020-2022, by Samuel Williams.
-# Copyright, 2020, by Olle Jonsson.
+# Copyright, 2020-2024, by Samuel Williams.
 
 require 'async/container'
 

examples/grace/server.rb

@@ -5,7 +5,7 @@
 # Copyright, 2024, by Samuel Williams.
 
 require '../../lib/async/container'
-require 'async/io/host_endpoint'
+require 'io/endpoint/host_endpoint'
 
 Console.logger.debug!
 

examples/http/server.rb

@@ -8,7 +8,6 @@
 
 require 'async/http/endpoint'
 require 'async/http/server'
-require 'async/io/shared_endpoint'
 
 container = Async::Container::Forked.new
 

examples/queue/server.rb

@@ -2,7 +2,7 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2020-2022, by Samuel Williams.
+# Copyright, 2020-2024, by Samuel Williams.
 
 require 'async'
 require 'async/container'

lib/async/container/notify/server.rb

@@ -1,11 +1,9 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2020-2022, by Samuel Williams.
+# Copyright, 2020-2024, by Samuel Williams.
 # Copyright, 2020, by Olle Jonsson.
 
-require 'async/io'
-require 'async/io/unix_endpoint'
 require 'kernel/sync'
 
 require 'tmpdir'
@@ -62,19 +60,13 @@ def bind
 				class Context
 					def initialize(path)
 						@path = path
-						@endpoint = IO::Endpoint.unix(@path, ::Socket::SOCK_DGRAM)
-
-						Sync do
-							@bound = @endpoint.bind
-						end
+						@bound = Addrinfo.unix(@path, ::Socket::SOCK_DGRAM).bind
 
 						@state = {}
 					end
 
 					def close
-						Sync do
-							@bound.close
-						end
+						@bound.close
 
 						File.unlink(@path)
 					end

lib/async/container/notify/socket.rb

@@ -1,12 +1,11 @@
 # frozen_string_literal: true
 
 # Released under the MIT License.
-# Copyright, 2020-2022, by Samuel Williams.
+# Copyright, 2020-2024, by Samuel Williams.
 
 require_relative 'client'
 
-require 'async/io'
-require 'async/io/unix_endpoint'
+require 'io/endpoint/unix_endpoint'
 require 'kernel/sync'
 
 module Async
@@ -32,7 +31,7 @@ def self.open!(environment = ENV)
 				# @parameter path [String] The path to the UNIX socket used for sending messages to the process manager.
 				def initialize(path)
 					@path = path
-					@endpoint = IO::Endpoint.unix(path, ::Socket::SOCK_DGRAM)
+					@endpoint = ::IO::Endpoint.unix(path, ::Socket::SOCK_DGRAM)
 				end
 
 				# Dump a message in the format requied by `sd_notify`.
@@ -65,7 +64,7 @@ def send(**message)
 
 					Sync do
 						@endpoint.connect do |peer|
-							peer.send(data)
+							peer.sendmsg(data)
 						end
 					end
 				end