Contents

# frozen_string_literal: true

# Released under the MIT License.
# Copyright, 2023, by Samuel Williams.

require_relative 'generic'

module IO::Endpoint
	# A composite endpoint is a collection of endpoints that are used in order.
	class CompositeEndpoint < Generic
		def initialize(endpoints, **options)
			super(**options)
			@endpoints = endpoints
		end
		
		def each(&block)
			@endpoints.each do |endpoint|
				endpoint.each(&block)
			end
		end
		
		def connect(wrapper = Wrapper.default, &block)
			last_error = nil
			
			@endpoints.each do |endpoint|
				begin
					return endpoint.connect(wrapper, &block)
				rescue => last_error
				end
			end
			
			raise last_error
		end
		
		def bind(wrapper = Wrapper.default, &block)
			if block_given?
				@endpoints.each do |endpoint|
					endpoint.bind(&block)
				end
			else
				@endpoints.map(&:bind).flatten.compact
			end
		end
	end
	
	def self.composite(*endpoints, **options)
		CompositeEndpoint.new(endpoints, **options)
	end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
io-endpoint-0.10.1	lib/io/endpoint/composite_endpoint.rb
io-endpoint-0.10.0	lib/io/endpoint/composite_endpoint.rb
io-endpoint-0.9.0	lib/io/endpoint/composite_endpoint.rb
io-endpoint-0.8.1	lib/io/endpoint/composite_endpoint.rb
io-endpoint-0.8.0	lib/io/endpoint/composite_endpoint.rb
io-endpoint-0.7.2	lib/io/endpoint/composite_endpoint.rb
io-endpoint-0.7.1	lib/io/endpoint/composite_endpoint.rb
io-endpoint-0.7.0	lib/io/endpoint/composite_endpoint.rb
io-endpoint-0.6.0	lib/io/endpoint/composite_endpoint.rb
io-endpoint-0.5.0	lib/io/endpoint/composite_endpoint.rb