Sha256: 1d4fcef7594e631c4df32042a69cc7213ed5a73714e15e81718e588e6dcf136c

Contents?: true

Size: 501 Bytes

Versions: 1

Compression:

Stored size: 501 Bytes

Contents

# frozen_string_literal: true

# Released under the MIT License.
# Copyright, 2018-2023, 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.connected?
					end
					
					def reusable?
						!@stream.closed?
					end
				end
				
				def self.client(stream)
					Connection.new(stream)
				end
			end
		end
	end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
async-redis-0.8.0 lib/async/redis/protocol/resp2.rb