Open Sidebar
Close Sidebar
CrystalDoc.info
Source code
Shards.info
redis
v0.3.0
Redis
BusyGroup
Client
Cluster
Ask
CrossSlot
Error
Moved
Commands
XGroup
Connection
Error
FullText
GeoUnit
SortBy
SortDirection
Future
NotResolved
Graph
Client
Error
List
Map
Node
Property
Result
ResultValue
JSON
NoGroup
Parser
Pipeline
Streaming
Message
XAutoClaimResponse
XPendingBaseResponse
Data
XPendingExtendedResponse
MessageData
XReadGroupResponse
Result
TimeSeries
DuplicatePolicy
Encoding
Range
RangeOptions
Aggregation
AggregationType
Transaction
Value
Built with Crystal 1.9.2
2023-10-08 19:54:40 UTC
struct
Redis::Streaming::XPendingExtendedResponse
Redis::Streaming::XPendingExtendedResponse
Struct
Value
Object
Defined in:
streaming.cr
Constructors
.new
(data : Array, now : Time =
Time
.utc)
Instance Method Summary
#messages
: Array(MessageData)
Constructor Detail
def self.
new
(data : Array, now : Time =
Time
.utc)
#
[
View source
]
Instance Method Detail
def
messages
: Array(
MessageData
)
#
[
View source
]