Class: Takagi::ObserveRegistry

Inherits:
Object
  • Object
show all
Defined in:
sig/takagi/observe_registry.rbs

Overview

Keeps track of observers and broadcasts state changes to interested parties.

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.subscriptions ⇒ Object (readonly)

Returns the value of attribute subscriptions.

Returns:

  • (Object) 


10
11
12
 
# File 'sig/takagi/observe_registry.rbs', line 10

def subscriptions
  @subscriptions
end

Class Method Details

.cleanup_stale_observers ⇒ Object

Parameters:

  • max_age: (Object)
  • now: (Object)

Returns:

  • (Object) 


22
 
# File 'sig/takagi/observe_registry.rbs', line 22

def self.cleanup_stale_observers: (max_age: untyped, ?now: untyped) -> untyped

.deliver_notification ⇒ Object

Parameters:

  • subscription (Object)
  • path (Object)
  • new_value (Object)

Returns:

  • (Object) 


30
 
# File 'sig/takagi/observe_registry.rbs', line 30

def self.deliver_notification: (untyped subscription, untyped path, untyped new_value) -> untyped

.delta_exceeded? ⇒ Object

Parameters:

  • last_value (Object)
  • new_value (Object)
  • threshold (Object)

Returns:

  • (Object) 


28
 
# File 'sig/takagi/observe_registry.rbs', line 28

def self.delta_exceeded?: (untyped last_value, untyped new_value, untyped threshold) -> untyped

.notify ⇒ nil, untyped

Parameters:

  • path (Object)
  • new_value (Object)

Returns:

  • (nil, untyped) 


16
 
# File 'sig/takagi/observe_registry.rbs', line 16

def self.notify: (untyped path, untyped new_value) -> (nil | untyped)

.sender ⇒ Object

Returns:

  • (Object) 


18
 
# File 'sig/takagi/observe_registry.rbs', line 18

def self.sender: () -> untyped

.should_notify? ⇒ true, untyped

Parameters:

  • subscription (Object)
  • new_value (Object)

Returns:

  • (true, untyped) 


26
 
# File 'sig/takagi/observe_registry.rbs', line 26

def self.should_notify?: (untyped subscription, untyped new_value) -> (true | untyped)

.stale_subscription? ⇒ false, untyped

Parameters:

  • subscription (Object)
  • cutoff (Object)

Returns:

  • (false, untyped) 


34
 
# File 'sig/takagi/observe_registry.rbs', line 34

def self.stale_subscription?: (untyped subscription, untyped cutoff) -> (false | untyped)

.subscribe ⇒ Object

Parameters:

  • path (Object)
  • subscriber (Object)

Returns:

  • (Object) 


12
 
# File 'sig/takagi/observe_registry.rbs', line 12

def self.subscribe: (untyped path, untyped subscriber) -> untyped

.subscription_paths ⇒ Object

Returns:

  • (Object) 


20
 
# File 'sig/takagi/observe_registry.rbs', line 20

def self.subscription_paths: () -> untyped

.unsubscribe ⇒ Object

Parameters:

  • path (Object)
  • token (Object)

Returns:

  • (Object) 


14
 
# File 'sig/takagi/observe_registry.rbs', line 14

def self.unsubscribe: (untyped path, untyped token) -> untyped

.update_sequence ⇒ Object

Parameters:

  • subscription (Object)
  • new_value (Object)

Returns:

  • (Object) 


32
 
# File 'sig/takagi/observe_registry.rbs', line 32

def self.update_sequence: (untyped subscription, untyped new_value) -> untyped