Class: RedisIPC::Stream::Ledger::Entry

Inherits:

Object

Object
RedisIPC::Stream::Ledger::Entry

show all

Defined in:: lib/redis_ipc/stream/ledger.rb

Instance Method Summary collapse

#expired? ⇒ Boolean
#initialize ⇒ Entry constructor
A new instance of Entry.

Constructor Details

#initialize ⇒ `Entry`

Returns a new instance of Entry.



12
13
14

# File 'lib/redis_ipc/stream/ledger.rb', line 12

def initialize(**)
  super(mailbox: Concurrent::MVar.new, **)
end

Instance Method Details

#expired? ⇒ `Boolean`

Returns:

(Boolean)



16
17
18

# File 'lib/redis_ipc/stream/ledger.rb', line 16

def expired?
  Time.current >= expires_at
end