struct Redis::Streaming::XReadGroupResponse

• Redis::Streaming::XReadGroupResponse
• Struct
• Value
• Object

Overview

Transform the XREADGROUP result into a more friendly object.

Included Modules

• Enumerable(Redis::Streaming::XReadGroupResponse::Result)

Defined in:

streaming.cr

Constructors

• .new(response : Array(Redis::Value))

Class Method Summary

• .hash(response : Array(Redis::Value))

Instance Method Summary

• #each(*args, **options)
• #each(*args, **options, &)
• #each_message
• #each_message(&)
• #results : Array(Result)

Constructor Detail

Class Method Detail

Instance Method Detail