Sha256: 4603286f2f35a1ae74321073b53bfbdd41492ccbd783086155e32cb3866d57b6

Contents?: true

Size: 500 Bytes

Versions: 4

Compression:

Stored size: 500 Bytes

Contents

# frozen_string_literal: true

# Released under the MIT License.
# Copyright, 2018-2024, by Samuel Williams.

require 'protocol/redis'

module Async
	module Redis
		module Protocol
			module RESP2
				class Connection < ::Protocol::Redis::Connection
					def concurrency
						1
					end
					
					def viable?
						@stream.readable?
					end
					
					def reusable?
						!@stream.closed?
					end
				end
				
				def self.client(stream)
					Connection.new(stream)
				end
			end
		end
	end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
async-redis-0.10.1 lib/async/redis/protocol/resp2.rb
async-redis-0.10.0 lib/async/redis/protocol/resp2.rb
async-redis-0.9.0 lib/async/redis/protocol/resp2.rb
async-redis-0.8.1 lib/async/redis/protocol/resp2.rb