Contents

# frozen_string_literal: true

# Released under the MIT License.
# Copyright, 2018, by Huba Nagy.
# Copyright, 2018-2023, by Samuel Williams.

require_relative 'generic'

module Async
	module Redis
		module Context
			class Subscribe < Generic
				MESSAGE = 'message'
				
				def initialize(pool, channels)
					super(pool)
					
					subscribe(channels)
				end
				
				def close
					# There is no way to reset subscription state. On Redis v6+ you can use RESET, but this is not supported in <= v6.
					@connection&.close
					
					super
				end
				
				def listen
					while response = @connection.read_response
						return response if response.first == MESSAGE
					end
				end
				
				def subscribe(channels)
					@connection.write_request ['SUBSCRIBE', *channels]
					@connection.flush
				end
				
				def unsubscribe(channels)
					@connection.write_request ['UNSUBSCRIBE', *channels]
					@connection.flush
				end
			end
		end
	end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
async-redis-0.10.1	lib/async/redis/context/subscribe.rb
async-redis-0.10.0	lib/async/redis/context/subscribe.rb
async-redis-0.9.0	lib/async/redis/context/subscribe.rb
async-redis-0.8.1	lib/async/redis/context/subscribe.rb
async-redis-0.8.0	lib/async/redis/context/subscribe.rb