From dc294bb63ee2d21537a6469eb581e7e15560017b Mon Sep 17 00:00:00 2001
From: Denis Knauf <Denis.Knauf@gmail.com>
Date: Sat, 20 Mar 2010 23:24:49 +0100
Subject: [PATCH 1/6] little changes: metafiles

---
 Rakefile | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/Rakefile b/Rakefile
index 01c6483..f737155 100644
--- a/Rakefile
+++ b/Rakefile
@@ -10,8 +10,8 @@ begin
     gem.email = "Denis.Knauf@gmail.com"
     gem.homepage = "http://github.com/DenisKnauf/select"
     gem.authors = ["Denis Knauf"]
-    gem.files = ["README", "VERSION", "lib/**/*.rb", "test/**/*.rb"]
-    gem.require_paths = ["lib"]
+    gem.files = %w[README.md VERSION lib/**/*.rb test/**/*.rb]
+    gem.require_paths = %w[lib]
   end
   Jeweler::GemcutterTasks.new
 rescue LoadError

From 66ce7eb20949bc412375dd8c8e3f487734b6af2f Mon Sep 17 00:00:00 2001
From: Denis Knauf <Denis.Knauf@gmail.com>
Date: Wed, 31 Mar 2010 00:19:43 +0200
Subject: [PATCH 2/6] exit_on_empty default true!

---
 lib/select.rb | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/select.rb b/lib/select.rb
index 1af7859..c347bc9 100644
--- a/lib/select.rb
+++ b/lib/select.rb
@@ -20,7 +20,7 @@ class Select
 	def initialize timeout = 30
 		@read, @write, @error = {}, {}, {}
 		@read.default = @write.default = @error.default = lambda{}
-		@timeout, @tevent, @exit = timeout, lambda{}, false
+		@timeout, @tevent, @exit, @exit_on_empty = timeout, lambda{}, false, true
 	end
 
 	def timeout timeout = nil, &event

From 17f37684532e05504a3979954609778ea84c8bf3 Mon Sep 17 00:00:00 2001
From: Denis Knauf <Denis.Knauf@gmail.com>
Date: Wed, 6 Jul 2011 05:23:46 -0700
Subject: [PATCH 3/6] lambda{} want to have 0 arguments and raises
 ArgumentError. proc{} doesn't.

---
 lib/select.rb | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/lib/select.rb b/lib/select.rb
index c347bc9..61514f5 100644
--- a/lib/select.rb
+++ b/lib/select.rb
@@ -19,8 +19,8 @@ class Select
 
 	def initialize timeout = 30
 		@read, @write, @error = {}, {}, {}
-		@read.default = @write.default = @error.default = lambda{}
-		@timeout, @tevent, @exit, @exit_on_empty = timeout, lambda{}, false, true
+		@read.default = @write.default = @error.default = proc{}
+		@timeout, @tevent, @exit, @exit_on_empty = timeout, proc{}, false, true
 	end
 
 	def timeout timeout = nil, &event

From d265ec4d8c0739421a1f44a11c99714348cafff1 Mon Sep 17 00:00:00 2001
From: Denis Knauf <Denis.Knauf@gmail.com>
Date: Wed, 6 Jul 2011 15:35:36 +0200
Subject: [PATCH 4/6] #at added: at a timestamp, please do something

---
 lib/select.rb | 49 ++++++++++++++++++++++++++++++++++++++++++-------
 1 file changed, 42 insertions(+), 7 deletions(-)

diff --git a/lib/select.rb b/lib/select.rb
index 61514f5..9d92d90 100644
--- a/lib/select.rb
+++ b/lib/select.rb
@@ -18,7 +18,7 @@ class Select
 	end
 
 	def initialize timeout = 30
-		@read, @write, @error = {}, {}, {}
+		@read, @write, @error, @times = {}, {}, {}, []
 		@read.default = @write.default = @error.default = proc{}
 		@timeout, @tevent, @exit, @exit_on_empty = timeout, proc{}, false, true
 	end
@@ -68,22 +68,57 @@ class Select
 
 	def run_once timeout = @timeout
 		r, w, e = Kernel.select( @read.keys, @write.keys, @error.keys, timeout)
-		return @tevent.call  unless r or w or e
-		r.each {|h|   @read[ h].call h, :read   }
-		w.each {|h|  @write[ h].call h, :write  }
-		e.each {|h|  @error[ h].call h, :error  }
+		r and r.each {|h|   @read[ h].call h, :read   }
+		w and w.each {|h|  @write[ h].call h, :write  }
+		e and e.each {|h|  @error[ h].call h, :error  }
 	end
 
 	def run &e
 		if e
 			until @exit || (@exit_on_empty && self.empty?)
-				self.run_once
+				cron
+				self.run_once 1
 				e.call
 			end
 		else
-			self.run_once  until @exit || (@exit_on_empty && self.empty?)
+			until @exit || (@exit_on_empty && self.empty?)
+				cron
+				self.run_once 1
+			end
 		end
 	end
+
+	attr_reader :times
+	def cron
+		@times.each do |e|
+			return if e > Time.now
+			e.call
+			@times.shift
+		end
+	end
+
+	class Entry < Time
+		attr_reader :do
+		def do &e
+			@do = e
+		end
+
+		def call *p
+			@do.call *p
+		end
+
+		def self.new *a, &e
+			x = self.at *a
+			x.do &e
+			x
+		end
+	end
+
+	def at a, &e
+		a = Entry.new a, &e if e
+		@times << a
+		@times.sort!
+	end
 end
 
 class Select::Buffer <String

From 07598fc954f45f3a01076efb8d08bda9e86e076f Mon Sep 17 00:00:00 2001
From: Denis Knauf <deac@denkn.at>
Date: Thu, 25 Aug 2016 22:28:32 +0200
Subject: [PATCH 5/6] README.md added. select: on/off/one (like event-based
 jquery).

---
 README.md     |   4 ++
 lib/select.rb | 171 +++++++++++++++++++++++++++++++++++++-------------
 2 files changed, 130 insertions(+), 45 deletions(-)
 create mode 100644 README.md

diff --git a/README.md b/README.md
new file mode 100644
index 0000000..03aab8a
--- /dev/null
+++ b/README.md
@@ -0,0 +1,4 @@
+Select
+======
+
+IO-Management select-based.
diff --git a/lib/select.rb b/lib/select.rb
index 9d92d90..306285a 100644
--- a/lib/select.rb
+++ b/lib/select.rb
@@ -1,87 +1,168 @@
+# IO-Management
+# Fires if IO is ready a given block.
+#
+#   Select.open do |sel|
+#     sock = TCPSocket.new 'localhost', 8090
+#     buffer = ''
+#
+#     sel.on_read serv do |sock|
+#				buffer << sock.sysread
+#     end
+#
+#     sel.on_write STDOUT do |sock|
+#       return  if buffer.empty?
+#       written = sock.syswrite buffer
+#       buffer = buffer[written..-1]
+#     end
+#
+#     sel.on_error sock do |sock|
+#			  sel.close
+#     end
+#   end
+
 class Select
 	READ, WRITE, ERROR = 1, 2, 3
 
 	attr_reader :read, :write, :error
 	attr_accessor :exit, :exit_on_empty
 
+	# There are no events to wait?
 	def empty?
 		@read.empty? && @write.empty? && @error.empty?
 	end
 
-	def self.new *p, &e
-		r = super *p
-		if e
-			e.call r
-			r.close
-		else r
+	class <<self
+		# Creates a new Select-instance.
+		# If you use a block, Select will close all IOs on end.
+		def self.new *args, &exe
+			r = super *args
+			if exe
+				yield r
+				r.close
+			else r
+			end
 		end
+		alias open new
 	end
 
 	def initialize timeout = 30
 		@read, @write, @error, @times = {}, {}, {}, []
 		@read.default = @write.default = @error.default = proc{}
 		@timeout, @tevent, @exit, @exit_on_empty = timeout, proc{}, false, true
+		@pause = {read: {}, write: {}, error: {}}
 	end
 
 	def timeout timeout = nil, &event
 		return @timeout  if timeout.nil?
-		raise ArgumentError, "Numeric value expected, not: '#{timeout}'"  unless timeout.kind_of? Numeric
+		raise ArgumentError, "Numeric value expected, not: '#{timeout}'"  unless Numeric === timeout
 		@timeout = timeout
 		@tevent = event  if event
 		timeout
 	end
 
-	def set hook, type = :read, &event
-		raise ArgumentError, "This hook isn't supported: '#{hook.inspect}'"  unless hook.kind_of? IO
-		raise ArgumentError, "Unexpected Event: '#{event.inspect}'"  unless event.kind_of? Proc
+	def set io, type = :read, &event
+		#raise ArgumentError, "This io isn't supported: '#{io.inspect}'"  unless IO === io
+		#raise ArgumentError, "Unexpected Event: '#{event.inspect}'"  unless Proc === event
 		case type
-		when  READ, :read   then  @read[ hook] = event
-		when WRITE, :write  then @write[ hook] = event
-		when ERROR, :error  then @error[ hook] = event
-		when nil
-			@read[ hook] = event
-			@write[ hook] = event
-			@error[ hook] = event
-		else raise ArgumentError, "Unknown event-type: '#{type}'"
+		when  READ, :read   then  @read[ io] = event
+		when WRITE, :write  then @write[ io] = event
+		when ERROR, :error  then @error[ io] = event
+		when nil, :all
+			@read[ io] = event
+			@write[ io] = event
+			@error[ io] = event
+		else
+			raise ArgumentError, "Unknown event-type: '#{type}'"
+		end
+	end
+	alias on set
+
+	def pause io, type = :read
+		case type
+		when  READ, :read   then @pause[ :read][  io] = @read.delete io
+		when WRITE, :write  then @pause[ :write][ io] = @write.delete io
+		when ERROR, :error  then @pause[ :error][ io] = @error.delete io
+		when nil, :all
+			@pause[ :read][ io] = @read.delete io
+			@pause[ :write][ io] = @write.delete io
+			@pause[ :error][ io] = @error.delete io
+		else
+			raise ArgumentError, "Unknown event-type: '#{type}'"
 		end
 	end
 
-	def del hook, type = nil
+	def unpause io, type = :read
 		case type
-		when  READ, :read   then @read.delete hook
-		when WRITE, :write  then @write.delete hook
-		when ERROR, :error  then @error.delete hook
-		when nil
-			@read.delete hook
-			@write.delete hook
-			@error.delete hook
-		else raise ArgumentError, "Unknown event-type: '#{type}'"
+		when  READ, :read   then @read[  io] = @pause[ :read].delete io
+		when WRITE, :write  then @write[ io] = @pause[ :write].delete io
+		when ERROR, :error  then @error[ io] = @pause[ :error].delete io
+		when nil, :all
+			@read[  io] = @pause[ :read].delete io
+			@write[ io] = @pause[ :write].delete io
+			@error[ io] = @pause[ :error].delete io
+		else
+			raise ArgumentError, "Unknown event-type: '#{type}'"
 		end
 	end
 
-	def  read_set( hook, &event)  self.set hook,  :read, &event  end
-	def write_set( hook, &event)  self.set hook, :write, &event  end
-	def error_set( hook, &event)  self.set hook, :error, &event  end
-	def  read_del( hook)   @read.delete hook  end
-	def write_del( hook)  @write.delete hook  end
-	def error_del( hook)  @error.delete hook  end
+	# Removes object from notification.
+	# If type is read/write/error, only this, else all.
+	def del io, type = nil
+		case type
+		when  READ, :read   then @read.delete io
+		when WRITE, :write  then @write.delete io
+		when ERROR, :error  then @error.delete io
+		when nil, :all
+			@read.delete io
+			@write.delete io
+			@error.delete io
+		else
+			raise ArgumentError, "Unknown event-type: '#{type}'"
+		end
+	end
+	alias off del
 
-	def run_once timeout = @timeout
+	def  read_set( io, &event)  self.set io,  :read, &event  end
+	def write_set( io, &event)  self.set io, :write, &event  end
+	def error_set( io, &event)  self.set io, :error, &event  end
+	def  read_del( io)   @read.delete io  end
+	def write_del( io)  @write.delete io  end
+	def error_del( io)  @error.delete io  end
+	alias on_read read_set
+	alias on_write write_set
+	alias on_error error_set
+	alias off_read read_del
+	alias off_write write_del
+	alias off_error error_del
+
+	# only once this will be fired
+	def one io, type = :read, &exe
+		on io, type do |*args|
+			off io, type
+			yield *args
+		end
+	end
+
+	# Runs once.
+	# Every ready disposed to read/write or has an error, will be fired.
+	def run_once timeout = nil
+		timeout ||= @timeout
 		r, w, e = Kernel.select( @read.keys, @write.keys, @error.keys, timeout)
 		r and r.each {|h|   @read[ h].call h, :read   }
 		w and w.each {|h|  @write[ h].call h, :write  }
 		e and e.each {|h|  @error[ h].call h, :error  }
 	end
 
+	# Runs in a loop
 	def run &e
 		if e
-			until @exit || (@exit_on_empty && self.empty?)
+			until @exit || (@exit_on_empty && empty?)
 				cron
 				self.run_once 1
 				e.call
 			end
 		else
-			until @exit || (@exit_on_empty && self.empty?)
+			until @exit || (@exit_on_empty && empty?)
 				cron
 				self.run_once 1
 			end
@@ -152,11 +233,11 @@ class Select::Socket
 		@select.error_set @sock, &method( :event_error)
 	end
 
-	def init opts
-		@select  = opts[ :select]  || Select.new
-		@sock    = opts[ :sock]    || raise( ArgumentError, "need sock")
-		@bufsize = opts[ :bufsize] || 4096
-		@parent  = opts[ :parent]  || nil
+	def init sock: , delimiter: nil, select: nil, bufsize: nil, parent: nil
+		@sock    = sock
+		@select  = select  || Select.new
+		@bufsize = bufsize || 4096
+		@parent  = parent  || nil
 		self.delimiter = opts[ :delimiter] || $/
 		@linebuf, @writebuf = Select::Buffer.new(""), Select::Buffer.new("")
 	end
@@ -242,10 +323,10 @@ class Select::Server
 		select.read_set @sock, &self.method( :event_conn)
 	end
 
-	def init opts
-		@sock = opts[ :sock] || raise( ArgumentError, "need sock")
-		@select = opts[ :select] || Select.new
-		@clientclass = opts[ :clientclass] || Select::Socket
+	def init sock: , select: nil, clientclass: nil
+		@sock = sock
+		@select = select || Select.new
+		@clientclass = clientclass || Select::Socket
 		@clients = []
 	end
 

From 42a62ae1122206247447ed27c329fb9ff23788cb Mon Sep 17 00:00:00 2001
From: Denis Knauf <deac@denkn.at>
Date: Thu, 25 Aug 2016 22:33:27 +0200
Subject: [PATCH 6/6] Rakefile updated, license defined

---
 .gitignore |  1 +
 Rakefile   | 71 +++++++++++++++++++++++++++---------------------------
 2 files changed, 37 insertions(+), 35 deletions(-)
 create mode 100644 .gitignore

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..fc5bd90
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1 @@
+/pkg
diff --git a/Rakefile b/Rakefile
index f737155..2084b4a 100644
--- a/Rakefile
+++ b/Rakefile
@@ -2,56 +2,57 @@ require 'rubygems'
 require 'rake'
 
 begin
-  require 'jeweler'
-  Jeweler::Tasks.new do |gem|
-    gem.name = "select"
-    gem.summary = %Q{IO-event-handler based on select}
-    gem.description = %Q{Select based event-handler for servers and sockets}
-    gem.email = "Denis.Knauf@gmail.com"
-    gem.homepage = "http://github.com/DenisKnauf/select"
-    gem.authors = ["Denis Knauf"]
-    gem.files = %w[README.md VERSION lib/**/*.rb test/**/*.rb]
-    gem.require_paths = %w[lib]
-  end
-  Jeweler::GemcutterTasks.new
+	require 'jeweler'
+	Jeweler::Tasks.new do |gem|
+		gem.name = "select"
+		gem.summary = %Q{IO-event-handler based on select}
+		gem.description = %Q{Select based event-handler for servers and sockets}
+		gem.email = "ich@denkn.at"
+		gem.license = 'LGPL-3.0'
+		gem.homepage = "http://github.com/DenisKnauf/select"
+		gem.authors = ["Denis Knauf"]
+		gem.files = %w[README.md VERSION lib/**/*.rb test/**/*.rb]
+		gem.require_paths = %w[lib]
+	end
+	Jeweler::GemcutterTasks.new
 rescue LoadError
-  puts "Jeweler (or a dependency) not available. Install it with: sudo gem install jeweler"
+	puts "Jeweler (or a dependency) not available. Install it with: sudo gem install jeweler"
 end
 
 require 'rake/testtask'
 Rake::TestTask.new(:test) do |test|
-  test.libs << 'lib' << 'test' << 'ext'
-  test.pattern = 'test/**/*_test.rb'
-  test.verbose = true
+	test.libs << 'lib' << 'test' << 'ext'
+	test.pattern = 'test/**/*_test.rb'
+	test.verbose = true
 end
 
 begin
-  require 'rcov/rcovtask'
-  Rcov::RcovTask.new do |test|
-    test.libs << 'test'
-    test.pattern = 'test/**/*_test.rb'
-    test.verbose = true
-  end
+	require 'rcov/rcovtask'
+	Rcov::RcovTask.new do |test|
+		test.libs << 'test'
+		test.pattern = 'test/**/*_test.rb'
+		test.verbose = true
+	end
 rescue LoadError
-  task :rcov do
-    abort "RCov is not available. In order to run rcov, you must: sudo gem install spicycode-rcov"
-  end
+	task :rcov do
+		abort "RCov is not available. In order to run rcov, you must: sudo gem install spicycode-rcov"
+	end
 end
 
 task :test => :check_dependencies
 
 task :default => :test
 
-require 'rake/rdoctask'
+require 'rdoc/task'
 Rake::RDocTask.new do |rdoc|
-  if File.exist?('VERSION')
-    version = File.read('VERSION')
-  else
-    version = ""
-  end
+	if File.exist?('VERSION')
+		version = File.read('VERSION')
+	else
+		version = ""
+	end
 
-  rdoc.rdoc_dir = 'rdoc'
-  rdoc.title = "sbdb #{version}"
-  rdoc.rdoc_files.include('README*')
-  rdoc.rdoc_files.include('lib/**/*.rb')
+	rdoc.rdoc_dir = 'rdoc'
+	rdoc.title = "select #{version}"
+	rdoc.rdoc_files.include('README*')
+	rdoc.rdoc_files.include('lib/**/*.rb')
 end