Add GtAnnounceingTimeCachedObject

src/GToolkit-Utility-Basic/GtAnnouncingTimeCachedObject.class.st

@@ -0,0 +1,77 @@
+"
+GtAnnouncingTimeCachedObject extends GtTimeCachedObject to update values in the background and announce when they are available.
+
+If `retrievingValue` is nil, the last known value is used, otherwise the `retrievingValue` is answered.
+"
+Class {
+	#name : #GtAnnouncingTimeCachedObject,
+	#superclass : #GtTimeCachedObject,
+	#instVars : [
+		'announcer',
+		'retrievingMessage'
+	],
+	#category : #'GToolkit-Utility-Basic'
+}
+
+{ #category : #'instance creation' }
+GtAnnouncingTimeCachedObject class >> get: aBlock timeout: aDuration [
+
+	^ self new initialize: aBlock timeout: aDuration
+]
+
+{ #category : #'instance creation' }
+GtAnnouncingTimeCachedObject class >> get: aBlock timeout: aDuration announcer: anAnnouncer [
+
+	^ (self new initialize: aBlock timeout: aDuration)
+		announcer: anAnnouncer
+]
+
+{ #category : #'instance creation' }
+GtAnnouncingTimeCachedObject class >> get: aBlock timeout: aDuration announcer: anAnnouncer retrievingMessage: aString [
+
+	^ (self new initialize: aBlock timeout: aDuration)
+		announcer: anAnnouncer;
+		retrievingMessage: aString
+]
+
+{ #category : #accessing }
+GtAnnouncingTimeCachedObject >> announcer [
+	^ announcer
+]
+
+{ #category : #accessing }
+GtAnnouncingTimeCachedObject >> announcer: anObject [
+	announcer := anObject
+]
+
+{ #category : #accessing }
+GtAnnouncingTimeCachedObject >> retrievingMessage [
+	^ retrievingMessage
+]
+
+{ #category : #accessing }
+GtAnnouncingTimeCachedObject >> retrievingMessage: anObject [
+	retrievingMessage := anObject
+]
+
+{ #category : #private }
+GtAnnouncingTimeCachedObject >> updateAndAnnounce [
+
+	[ self newValue ] asAsyncPromise
+		then: [ :newValue |
+			[ announcer announce: (GtTimeCachedObjectAnnouncement
+				newValue: newValue cache: self) ]
+					on: Error
+					fork: [ :ex | self error: 'Unable to notify: ', ex errorMessage ] ]
+		otherwise: [ :ex |
+			self error: 'Unable to update: ', ex errorMessage ].
+]
+
+{ #category : #accessing }
+GtAnnouncingTimeCachedObject >> valueWithin: aDuration [
+	"Answer the receiver's value, updating it if the value is more than aDuration old"
+
+	DateAndTime now <= self cacheTimeout ifTrue: [ ^ value ].
+	self updateAndAnnounce.
+	^ retrievingMessage ifNil: [ value ].
+]

src/GToolkit-Utility-Basic/GtInheritedMethodsSortFunction.class.st

@@ -103,6 +103,11 @@ GtInheritedMethodsSortFunction >> compareMethodNameOf: aMethodOrName1 withMethod
 		ifFalse: [ methodName2 isBinary threeWayCompareTo: methodName1 isBinary ]
 ]
 
+{ #category : #comparing }
+GtInheritedMethodsSortFunction >> hash [
+	^ self class hash
+]
+
 { #category : #'private - comparison' }
 GtInheritedMethodsSortFunction >> hasMethodNameOf: aMethodOrName [
 	<return: #Symbol>
@@ -116,11 +121,6 @@ GtInheritedMethodsSortFunction >> hasMethodNameOf: aMethodOrName [
 	^ [ aMethodOrName selector notNil ] on: Error do: [ :ex | ex return: false ]
 ]
 
-{ #category : #comparing }
-GtInheritedMethodsSortFunction >> hash [
-	^ self class hash
-]
-
 { #category : #'private - comparison' }
 GtInheritedMethodsSortFunction >> methodNameOf: aMethodOrName [
 	<return: #Symbol>

src/GToolkit-Utility-Basic/GtMethodsSortFunction.class.st

@@ -114,6 +114,11 @@ GtMethodsSortFunction >> compareMethodNameOf: aMethodOrName1 withMethodNameOf: a
 		ifFalse: [ methodName2 isBinary threeWayCompareTo: methodName1 isBinary ]
 ]
 
+{ #category : #comparing }
+GtMethodsSortFunction >> hash [
+	^ self class hash
+]
+
 { #category : #'private - comparison' }
 GtMethodsSortFunction >> hasMethodNameOf: aMethodOrName [
 	<return: #Symbol>
@@ -127,11 +132,6 @@ GtMethodsSortFunction >> hasMethodNameOf: aMethodOrName [
 	^ [ aMethodOrName selector notNil ] on: Error do: [ :ex | ex return: false ]
 ]
 
-{ #category : #comparing }
-GtMethodsSortFunction >> hash [
-	^ self class hash
-]
-
 { #category : #'private - comparison' }
 GtMethodsSortFunction >> methodNameOf: aMethodOrName [
 	<return: #Symbol>

src/GToolkit-Utility-Basic/GtTimeCachedObjectAnnouncement.class.st

@@ -0,0 +1,37 @@
+Class {
+	#name : #GtTimeCachedObjectAnnouncement,
+	#superclass : #Announcement,
+	#instVars : [
+		'newValue',
+		'cache'
+	],
+	#category : #'GToolkit-Utility-Basic'
+}
+
+{ #category : #'instance creation' }
+GtTimeCachedObjectAnnouncement class >> newValue: anObject cache: aGtTimeCachedObject [
+
+	^ self new initializeValue: anObject from: aGtTimeCachedObject
+]
+
+{ #category : #'as yet unclassified' }
+GtTimeCachedObjectAnnouncement class >> value [
+	^ self
+]
+
+{ #category : #accessing }
+GtTimeCachedObjectAnnouncement >> cache [
+	^ cache
+]
+
+{ #category : #initialization }
+GtTimeCachedObjectAnnouncement >> initializeValue: anObject from: aGtTimeCachedObject [
+
+	newValue := anObject.
+	cache := aGtTimeCachedObject.
+]
+
+{ #category : #accessing }
+GtTimeCachedObjectAnnouncement >> newValue [
+	^ newValue
+]