Sha256: 0dbf7fa0505171bd6c42b456d6fd704cca2988e5f109ed4e586cf8fe0720db57

Contents?: true

Size: 500 Bytes

Versions: 1

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

1 entries across 1 versions & 1 rubygems

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