Squeak-dev October 2020

squeak-dev@lists.squeakfoundation.org

51 participants
394 discussions

The Inbox: PromisesTests-rww.10.mcz
by commits＠source.squeak.org 04 Oct '20

04 Oct '20

A new version of PromisesTests was added to project The Inbox: http://source.squeak.org/inbox/PromisesTests-rww.10.mcz ==================== Summary ==================== Name: PromisesTests-rww.10 Author: rww Time: 4 October 2020, 12:01:59.781672 pm UUID: 380cc875-64e7-41a3-ad9e-93cb54eeb338 Ancestors: PromisesTests-rww.9 calls includesKey: ==================== Snapshot ==================== SystemOrganization addCategory: #PromisesTests! ----- Method: Promise>>isFulfilled (in category '*promisestests') ----- isFulfilled ^ state == #fulfilled.! ----- Method: Promise>>isResolved (in category '*promisestests') ----- isResolved ^ self isFulfilled or: [self isRejected]! ----- Method: Promise>>rejectWith: (in category '*promisestests') ----- rejectWith: anObject "Reject this promise." | exception | mutex critical: [ exception := (anObject isKindOf: Exception) ifTrue: [anObject] ifFalse: [BrokenPromiseValue value: anObject]. (state == #pending) ifTrue: [ | worklist | error := exception. state := #rejected. worklist := rejecters. resolvers := #(). rejecters := #(). worklist do: [:r | self evaluateRejecter: r]] ifFalse: [PromiseAlreadyResolved new signal]]! ----- Method: Promise>>resolveWith: (in category '*promisestests') ----- resolveWith: arg "Resolve this promise. If arg is itself a Promise, make this promise depend upon it, as detailed in the Promises/A+ spec: https://promisesaplus.com/#the-promise-resolution-procedure" arg isPromise ifTrue: [ arg whenResolved: [:v | self resolveWith: v]. arg whenRejected: [:e | self rejectWith: e]] ifFalse: [ mutex critical: [ (arg isKindOf: Error) ifTrue: [^ self rejectWith: arg]. (state == #pending) ifTrue: [ | worklist | value := arg. state := #fulfilled. worklist := resolvers. resolvers := #(). rejecters := #(). worklist do: [:r | self evaluateResolver: r]] ifFalse: [PromiseAlreadyResolved new signal]]]! ----- Method: Promise>>wait (in category '*promisestests') ----- wait "Wait unconditionally for this promise to become fulfilled or rejected." | sema | sema := Semaphore new. self whenResolved:[sema signal]. self whenRejected:[sema signal]. sema wait. ^ self isFulfilled ifTrue: [ value ] ifFalse: [ self isRejected ifTrue: [ self error signal ] ifFalse: [ self ]]! ----- Method: Promise>>waitTimeoutMSecs: (in category '*promisestests') ----- waitTimeoutMSecs: msecs "Wait for at most the given number of milliseconds for this promise to settle. Answer true if it is resolved, false otherwise. False can therefore mean EITHER 'timeout' OR 'rejected'." | sema delay | sema := Semaphore new. self whenResolved: [sema signal]. self whenRejected: [sema signal]. delay := Delay timeoutSemaphore: sema afterMSecs: msecs. [sema wait] ensure: [delay unschedule]. ^ self isFulfilled ifTrue: [ value ] ifFalse: [ self isRejected ifTrue: [ self error signal ] ifFalse: [ self ]]! ----- Method: PromiseTest>>privateTestNilErrBlockPropagationResolvedReactorEvaluated (in category '*promisestests') ----- privateTestNilErrBlockPropagationResolvedReactorEvaluated "https://promisesaplus.com section 2.2.7.4" | p q | p := Promise new. q := p then: [:v | self error: 'Shouldn''t call resolvedBlock'] ifRejected: nil. p rejectWith: 1. self should: [q waitTimeoutMSecs: 1] raise: Error. self assert: p isRejected. self assert: q isRejected. self assert: p error class equals: BrokenPromiseValue. self assert: q error class equals: Error. self assert: p error value equals: 1. ! ----- Method: PromiseTest>>privateTestNilErrBlockPropagationResolvedReactorNotEvaluated (in category '*promisestests') ----- privateTestNilErrBlockPropagationResolvedReactorNotEvaluated "https://promisesaplus.com section 2.2.7.4" | p q | p := Promise new. q := p then: [:v | self error: 'Shouldn''t call resolvedBlock'] ifRejected: nil. p rejectWith: 1. self should: [q waitTimeoutMSecs: 1] raise: Error. self assert: p isRejected. self assert: q isRejected. self assert: p error class equals: BrokenPromiseValue. self assert: q error class equals: BrokenPromiseValue. self assert: p error value equals: 1. self assert: q error value equals: 1.! ----- Method: PromiseTest>>testAnErrorInOnRejectedRejectsPromise (in category '*promisestests') ----- testAnErrorInOnRejectedRejectsPromise "https://promisesaplus.com section 2.2.7.2" | p q error | p := Promise new. q := p ifRejected: [:e | (error := KeyNotFound new) signal]. p rejectWith: 1. self should: [q waitTimeoutMSecs: 1] raise: KeyNotFound. self assert: p isRejected description: 'Original Promise not rejected'. self assert: q isRejected description: 'Broken Promise not rejected'. self assert: p error class = BrokenPromiseValue. self assert: q error class = KeyNotFound. self assert: p error value == 1. self assert: q error == error.! ----- Method: PromiseTest>>testAnErrorInThenRejectsPromise (in category '*promisestests') ----- testAnErrorInThenRejectsPromise "https://promisesaplus.com section 2.2.7.2" | p q error | p := Promise new. q := p then: [:v | (error := KeyNotFound new) signal]. p resolveWith: 1. self should: [q waitTimeoutMSecs: 1] raise: KeyNotFound. self deny: p isRejected description: 'Original Promise rejected'. self assert: q isRejected description: 'Broken Promise not rejected'. self assert: p value = 1. self assert: q error == error.! ----- Method: PromiseTest>>testCannotRejectFulfilledPromise (in category '*promisestests') ----- testCannotRejectFulfilledPromise | p | p := Promise unit: 1. self should: [p rejectWith: Error new] raise: PromiseAlreadyResolved. self assert: p isResolved. self assert: 1 equals: p value. ! ----- Method: PromiseTest>>testCannotResolveaRejectedPromise (in category '*promisestests') ----- testCannotResolveaRejectedPromise | p e | p := Promise new. e := Error new. p rejectWith: e. self should: [p resolveWith: 1] raise: PromiseAlreadyResolved. self assert: p isRejected. self assert: p error == e. ! ----- Method: PromiseTest>>testChainedResolvers (in category '*promisestests') ----- testChainedResolvers | promise1 promise2 result | promise1 := Promise new. promise2 := Promise new. promise1 whenResolved: [:bool | promise2 resolveWith: bool not]. promise2 whenResolved: [:bool | result := bool]. promise1 resolveWith: false. promise2 waitTimeoutMSecs: 10. self should: [result].! ----- Method: PromiseTest>>testCollapsesChainsOfPromises (in category '*promisestests') ----- testCollapsesChainsOfPromises "The monadic bind operator has signature (m a -> (a -> m b) -> m b): that is, in our setting, the block given to `then:` is expected to return a *Promise* of a value, not a value directly. It is convenient to accept non-promise values and automatically lift them into the monad, but we must also ensure we treat the case where a `then:`-block yields a Promise correctly." | p q r | p := Promise new. q := p then: [:v | Promise unit: v * 2]. r := q then: [:v | Promise unit: v + 1]. p resolveWith: 4. q waitTimeoutMSecs: 1. r waitTimeoutMSecs: 1. self assert: 4 * 2 equals: q value. self assert: (4 * 2 + 1) equals: r value.! ----- Method: PromiseTest>>testFirstResolutionWins (in category '*promisestests') ----- testFirstResolutionWins | p | p := Promise new. p resolveWith: 1. self should: [p resolveWith: 2] raise: PromiseAlreadyResolved. self assert: p isResolved. self assert: p value == 1. ! ----- Method: PromiseTest>>testMultipleResolvers (in category '*promisestests') ----- testMultipleResolvers | promise sum | sum := 0. promise := Promise new. 5 timesRepeat: [ promise whenResolved: [:val | sum := sum + val]. ]. promise resolveWith: 5. (Delay forMilliseconds: 3) wait. self should: [sum = 25].! ----- Method: PromiseTest>>testNilErrBlockPropagation (in category '*promisestests') ----- testNilErrBlockPropagation "https://promisesaplus.com section 2.2.7.4" (Smalltalk includesKey: #PriorityVat) ifTrue: [self privateTestNilErrBlockPropagationResolvedReactorEvaluated] ifFalse: [self privateTestNilErrBlockPropagationResolvedReactorNotEvaluated].! ----- Method: PromiseTest>>testNilResolvedBlockPropagation (in category '*promisestests') ----- testNilResolvedBlockPropagation "https://promisesaplus.com section 2.2.7.3" | p q | p := Promise new. q := p then: nil ifRejected: [:e | self error: 'Shouldn''t call errBlock']. p resolveWith: 1. q waitTimeoutMSecs: 1.. self assert: p isResolved. self assert: q isResolved. self assert: p value equals: 1. self assert: q value equals: 1.! ----- Method: PromiseTest>>testRejectWithInvokesErrorHandlers (in category '*promisestests') ----- testRejectWithInvokesErrorHandlers | p error returnedError | returnedError := nil. error := KeyNotFound new. p := Promise ifRejected: [:e | returnedError := e]. p rejectWith: error. (Delay forMilliseconds: 1) wait. self assert: returnedError notNil description: 'Error block did not run.'. self assert: error equals: returnedError description: 'Error not passed into block'. self assert: error equals: p error description: 'Promise didn''t store error'.! ----- Method: PromiseTest>>testSingleResolver (in category '*promisestests') ----- testSingleResolver | promise sum | sum := 0. promise := Promise new. promise whenResolved: [:val | sum := sum + val]. promise resolveWith: 5. (Delay forMilliseconds: 1) wait. self assert: 5 equals: sum. ! ----- Method: PromiseTest>>testThenPermitsChainingOfPromises (in category '*promisestests') ----- testThenPermitsChainingOfPromises | p q r | p := Promise new. q := p then: [:v | v * 2]. r := q then: [:v | v + 1]. p resolveWith: 4. q waitTimeoutMSecs: 1. r waitTimeoutMSecs: 1. self assert: 4 * 2 equals: q value. self assert: (4 * 2 + 1) equals: r value.! ----- Method: PromiseTest>>testTimeout (in category '*promisestests') ----- testTimeout | promise | promise := Promise new. self should: [(promise waitTimeoutMSecs: 1) isPromise]. self shouldnt: [promise isResolved]. self shouldnt: [promise isRejected]. promise resolveWith: 45. self should: [(promise waitTimeoutMSecs: 1) == 45]. self should: [promise isResolved]. self shouldnt: [promise isRejected].! ----- Method: PromiseTest>>testTimeoutRejected (in category '*promisestests') ----- testTimeoutRejected | promise | promise := Promise new. self should: [(promise waitTimeoutMSecs: 1) isPromise]. self shouldnt: [promise isFulfilled]. self shouldnt: [promise isResolved]. self shouldnt: [promise isRejected]. promise rejectWith: 45. self should: [promise waitTimeoutMSecs: 1] raise: BrokenPromiseValue. self shouldnt: [promise isFulfilled]. self should: [promise isResolved]. self should: [promise isRejected].! ----- Method: PromiseTest>>testUnitReturnsaPromise (in category '*promisestests') ----- testUnitReturnsaPromise | p | p := Promise unit: 1. self assert: p isResolved.! ----- Method: PromiseTest>>testWaitForRejection (in category '*promisestests') ----- testWaitForRejection | p | p := Promise new. [ (Delay forMilliseconds: 1) wait. p rejectWith: Error new ] fork. self should: [ p wait ] raise: Error. ! ----- Method: PromiseTest>>testWaitForResolution (in category '*promisestests') ----- testWaitForResolution | p | p := Promise new. [ (Delay forMilliseconds: 1) wait. p resolveWith: #ok ] fork. p waitTimeoutMSecs: 3. self assert: [ p wait = #ok ]! ----- Method: PromiseTest>>testWaitRejectionYieldsCorrectBrokenPromise (in category '*promisestests') ----- testWaitRejectionYieldsCorrectBrokenPromise | p error | p := Promise new. [ (Delay forMilliseconds: 1) wait. p rejectWith: (error := Error new) ] fork. self should: [p wait] raise: Error. [ p wait ] on: Error do: [ :bp | ^ self assert: [ bp == error ] ]. self fail: 'Should not reach this point'! ----- Method: PromiseTest>>testifRejectedRunsBlockIfPromiseFails (in category '*promisestests') ----- testifRejectedRunsBlockIfPromiseFails "https://promisesaplus.com section 2.2.7.1" | p q error | error := nil. p := Promise new. q := p ifRejected: [:e | error := e "N.B. returns a value, does not signal an Exception"]. p rejectWith: KeyNotFound new. self should: [q waitTimeoutMSecs: 1] raise: KeyNotFound. self assert: q isResolved. self assert: q isRejected. self assert: KeyNotFound equals: error class. self assert: q error == error.! Error subclass: #BrokenPromiseValue instanceVariableNames: 'value' classVariableNames: '' poolDictionaries: '' category: 'PromisesTests'! ----- Method: BrokenPromiseValue class>>value: (in category 'instance creation') ----- value: obj ^ self new value: obj; yourself! ----- Method: BrokenPromiseValue>>defaultAction (in category 'handling') ----- defaultAction self messageText: 'Promise was rejected with value: ', value. ^super defaultAction! ----- Method: BrokenPromiseValue>>isResumable (in category 'handling') ----- isResumable ^ true! ----- Method: BrokenPromiseValue>>value (in category 'accessing') ----- value ^ value.! ----- Method: BrokenPromiseValue>>value: (in category 'accessing') ----- value: anObject value := anObject.! Error subclass: #PromiseAlreadyResolved instanceVariableNames: '' classVariableNames: '' poolDictionaries: '' category: 'PromisesTests'!

2 1

The Inbox: PromisesLocal-rww.20.mcz
by commits＠source.squeak.org 04 Oct '20

04 Oct '20

A new version of PromisesLocal was added to project The Inbox: http://source.squeak.org/inbox/PromisesLocal-rww.20.mcz ==================== Summary ==================== Name: PromisesLocal-rww.20 Author: rww Time: 4 October 2020, 10:43:29.453407 am UUID: ff0cd0f9-170e-4cfb-b64a-47a1b0446903 Ancestors: PromisesLocal-rww.19 use eventual sending to handle nil blocks, both the #then: block and the #ifRejected: block ==================== Snapshot ==================== SystemOrganization addCategory: #PromisesLocal! SystemOrganization addCategory: #'PromisesLocal-Testing'! Object subclass: #AbstractEventual instanceVariableNames: '' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: AbstractEventual class>>broken: (in category 'promises') ----- broken: error "self broken: Error new" ^ BrokenEventual new exception: error; yourself! ----- Method: AbstractEventual class>>isReference: (in category 'resolution') ----- isReference: object ^ object class includesBehavior: AbstractEventual ! ----- Method: AbstractEventual class>>promise (in category 'promises') ----- promise "self promise" ^ self promiseInVat: self vat. ! ----- Method: AbstractEventual class>>promiseClass (in category 'promises') ----- promiseClass ^ Promise ! ----- Method: AbstractEventual class>>promiseInVat: (in category 'promises') ----- promiseInVat: aVat "self promise" | promise buf | buf := OrderedCollection new: 0. promise := self promiseClass newOnBuffer: buf vat: aVat. ^ Association key: promise value: promise resolver ! ----- Method: AbstractEventual class>>refDescriptionString (in category 'accessing') ----- refDescriptionString ^ 'eventual'! ----- Method: AbstractEventual class>>resolution: (in category 'immediate') ----- resolution: obj ^ obj! ----- Method: AbstractEventual class>>resolverClass (in category 'promises') ----- resolverClass ^ LocalResolver ! ----- Method: AbstractEventual class>>toReferenceContext: (in category 'resolution') ----- toReferenceContext: value ^ self toReferenceContext: value vat: self vat. ! ----- Method: AbstractEventual class>>toReferenceContext:vat: (in category 'resolution') ----- toReferenceContext: value vat: vat (self isReference: value) ifTrue: [^ value]. (value isKindOf: Exception) ifTrue: [^ AbstractEventual broken: value] ifFalse: [^ NearEventual newOn: value vat: vat.]. ! ----- Method: AbstractEventual>>at: (in category 'overrides') ----- at: index | pair | pair := AbstractEventual promiseInVat: self vat. self redirectEventualMessage: (EventualMessageSend message: (Message selector: #at: argument: index) resolver: pair value). ^ pair key ! ----- Method: AbstractEventual>>at:put: (in category 'overrides') ----- at: index put: value | pair | pair := AbstractEventual promiseInVat: self vat. self redirectEventualMessage: (EventualMessageSend message: (Message selector: #at:put: arguments: {index. value}) resolver: pair value). ^ pair key ! ----- Method: AbstractEventual>>becomeContext: (in category 'messaging') ----- becomeContext: context self becomeForward: context. ! ----- Method: AbstractEventual>>doesNotUnderstand: (in category 'messaging') ----- doesNotUnderstand: aMessage ^ self redirectMessage: aMessage ! ----- Method: AbstractEventual>>eventual (in category 'accessing') ----- eventual ^ self! ----- Method: AbstractEventual>>eventualInVat: (in category 'accessing') ----- eventualInVat: aVat ^ self ! ----- Method: AbstractEventual>>isEventual (in category 'testing') ----- isEventual ^ true! ----- Method: AbstractEventual>>isFulfilled (in category 'testing') ----- isFulfilled ^ false! ----- Method: AbstractEventual>>isInteger (in category 'overrides') ----- isInteger | pair | pair := AbstractEventual promiseInVat: self vat. self redirectEventualMessage: (EventualMessageSend message: (Message selector: #isInteger) resolver: pair value). ^ pair key ! ----- Method: AbstractEventual>>isLocal (in category 'testing') ----- isLocal ^ true! ----- Method: AbstractEventual>>isNear (in category 'testing') ----- isNear ^ true! ----- Method: AbstractEventual>>isPassByConstruction (in category 'testing') ----- isPassByConstruction ^ false! ----- Method: AbstractEventual>>isPassByProxy (in category 'testing') ----- isPassByProxy ^ true! ----- Method: AbstractEventual>>isRejected (in category 'testing') ----- isRejected ^ false! ----- Method: AbstractEventual>>isRemote (in category 'testing') ----- isRemote ^ false! ----- Method: AbstractEventual>>isResolved (in category 'testing') ----- isResolved ^ false! ----- Method: AbstractEventual>>mustBeBoolean (in category 'messaging') ----- mustBeBoolean | context | context := thisContext sender. self resolution. context skipBackBeforeJump. ^ true! ----- Method: AbstractEventual>>printOn: (in category 'printing') ----- printOn: stream stream nextPutAll: self class name; nextPutAll: '::'; nextPutAll: self refDescriptionString; nextPutAll: '('. self vat printOn: stream. stream nextPutAll: ')'. ! ----- Method: AbstractEventual>>redirectMessage: (in category 'messaging') ----- redirectMessage: aMessage | pair | pair := AbstractEventual promiseInVat: self vat. self redirectEventualMessage: (EventualMessageSend message: aMessage resolver: pair value). ^ pair key ! ----- Method: AbstractEventual>>redirectMessageOneWay: (in category 'messaging') ----- redirectMessageOneWay: aMessage self redirectEventualMessage: (EventualMessageSend message: aMessage). ^ nil ! ----- Method: AbstractEventual>>refDescriptionString (in category 'printing') ----- refDescriptionString ^ self class refDescriptionString ! ----- Method: AbstractEventual>>rejectWith: (in category 'Promise/A+ protocol') ----- rejectWith: reason self subclassResponsibility! ----- Method: AbstractEventual>>resolution (in category 'accessing') ----- resolution ^ self! ----- Method: AbstractEventual>>resolveWith: (in category 'Promise/A+ protocol') ----- resolveWith: arg self subclassResponsibility! ----- Method: AbstractEventual>>send: (in category 'eventual sending') ----- send: selector | pair | pair := AbstractEventual promiseInVat: self vat. self redirectEventualMessage: (EventualMessageSend selector: selector resolver: pair value). ^ pair key ! ----- Method: AbstractEventual>>send:args: (in category 'eventual sending') ----- send: selector args: args | pair | pair := AbstractEventual promiseInVat: self vat. self redirectEventualMessage: (EventualMessageSend selector: selector arguments: args resolver: pair value). ^ pair key ! ----- Method: AbstractEventual>>sendOneWay: (in category 'eventual sending') ----- sendOneWay: selector self redirectEventualMessage: (EventualMessageSend selector: selector). ^ nil ! ----- Method: AbstractEventual>>sendOneWay:args: (in category 'eventual sending') ----- sendOneWay: selector args: args self redirectEventualMessage: (EventualMessageSend selector: selector arguments: args). ^ nil ! ----- Method: AbstractEventual>>wait (in category 'waiting') ----- wait "Wait unconditionally for this promise to become fulfilled or rejected." PromiseWaiter waitTimeoutMSecs: 1000 onPromise: self. ^ self resolution.! ----- Method: AbstractEventual>>waitTimeoutMSecs: (in category 'waiting') ----- waitTimeoutMSecs: msecs "Wait for at most the given number of milliseconds for this promise to settle. Answer true if it is resolved, false otherwise. False can therefore mean EITHER 'timeout' OR 'rejected'." PromiseWaiter waitTimeoutMSecs: msecs onPromise: self. ^ self resolution.! ----- Method: AbstractEventual>>waitTimeoutSeconds: (in category 'waiting') ----- waitTimeoutSeconds: secs "Wait for at most the given number of milliseconds for this promise to settle. Answer true if it is resolved, false otherwise. False can therefore mean EITHER 'timeout' OR 'rejected'." PromiseWaiter waitTimeoutSeconds: secs onPromise: self. ^ self resolution.! AbstractEventual subclass: #BrokenEventual instanceVariableNames: 'exception' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: BrokenEventual class>>refDescriptionString (in category 'accessing') ----- refDescriptionString ^ 'broken' ! ----- Method: BrokenEventual>>becomeContext: (in category 'messaging') ----- becomeContext: ref ^ self error: 'not switchable'! ----- Method: BrokenEventual>>doesNotUnderstand: (in category 'messaging') ----- doesNotUnderstand: aMessage ^ self exception signal! ----- Method: BrokenEventual>>error (in category 'accessing') ----- error ^ self exception! ----- Method: BrokenEventual>>exception (in category 'accessing') ----- exception ^exception! ----- Method: BrokenEventual>>exception: (in category 'accessing') ----- exception: anException exception := anException! ----- Method: BrokenEventual>>isBroken (in category 'testing') ----- isBroken ^ true! ----- Method: BrokenEventual>>isRejected (in category 'testing') ----- isRejected ^ true! ----- Method: BrokenEventual>>isResolved (in category 'testing') ----- isResolved ^ true! ----- Method: BrokenEventual>>printOn: (in category 'printing') ----- printOn: stream super printOn: stream. stream nextPutAll: '{'; nextPutAll: self exception description; nextPutAll: '}'. ! ----- Method: BrokenEventual>>redirectEventualMessage: (in category 'messaging') ----- redirectEventualMessage: anEventualMessage anEventualMessage receiver: exception. self vat schedule: anEventualMessage. ! ----- Method: BrokenEventual>>rejectWith: (in category 'Promise/A+ protocol') ----- rejectWith: arg PromiseAlreadyResolved new signal. ! ----- Method: BrokenEventual>>resolution (in category 'Promise/A+ protocol') ----- resolution ^ exception signal! ----- Method: BrokenEventual>>resolveWith: (in category 'Promise/A+ protocol') ----- resolveWith: arg PromiseAlreadyResolved new signal. ! ----- Method: BrokenEventual>>value (in category 'accessing') ----- value ^ exception! AbstractEventual subclass: #NearEventual instanceVariableNames: 'vat value' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: NearEventual class>>newOn: (in category 'instance creation') ----- newOn: anObject ^ self newOn: anObject vat: anObject vat. ! ----- Method: NearEventual class>>newOn:vat: (in category 'instance creation') ----- newOn: anObject vat: vat ^ self new initializeOnTarget: anObject vat: vat; yourself. ! ----- Method: NearEventual class>>refDescriptionString (in category 'accessing') ----- refDescriptionString ^ 'near'! ----- Method: NearEventual>>= (in category 'comparing') ----- = anObject "Answer whether the receiver and the argument represent the same object. If = is redefined in any subclass, consider also redefining the message hash." ^anObject = value! ----- Method: NearEventual>>basicEquality: (in category 'comparing') ----- basicEquality: anObject "Answer whether the receiver and the argument represent the same object. If = is redefined in any subclass, consider also redefining the message hash." ^value basicEquality: anObject! ----- Method: NearEventual>>becomeContext: (in category 'messaging') ----- becomeContext: context ! ----- Method: NearEventual>>hash (in category 'comparing') ----- hash ^value hash! ----- Method: NearEventual>>initializeOnTarget:vat: (in category 'initialization') ----- initializeOnTarget: anObject vat: aVat value := anObject. vat := aVat. ! ----- Method: NearEventual>>isFulfilled (in category 'testing') ----- isFulfilled ^ true! ----- Method: NearEventual>>isInteger (in category 'number protocol') ----- isInteger ^ value isInteger! ----- Method: NearEventual>>isPassByConstruction (in category 'serializing') ----- isPassByConstruction ^ value isPassByConstruction ! ----- Method: NearEventual>>isResolved (in category 'testing') ----- isResolved ^ true! ----- Method: NearEventual>>passByConstruction (in category 'serializing') ----- passByConstruction self isPassByConstruction ifTrue: [^ value] ifFalse: [self error: 'not passByConstruction']. ! ----- Method: NearEventual>>printOn: (in category 'printing') ----- printOn: stream stream nextPutAll: '{ '. value printOn: stream. stream nextPutAll: ' } >> '. super printOn: stream. ! ----- Method: NearEventual>>redirectEventualMessage: (in category 'messaging') ----- redirectEventualMessage: anEventualMessage anEventualMessage receiver: value. self vat schedule: anEventualMessage. ! ----- Method: NearEventual>>rejectWith: (in category 'Promise/A+ protocol') ----- rejectWith: arg PromiseAlreadyResolved new signal. ! ----- Method: NearEventual>>resolution (in category 'accessing') ----- resolution ^ value! ----- Method: NearEventual>>resolveWith: (in category 'Promise/A+ protocol') ----- resolveWith: arg PromiseAlreadyResolved new signal. ! ----- Method: NearEventual>>value (in category 'accessing') ----- value ^ value! ----- Method: NearEventual>>vat (in category 'accessing') ----- vat ^ vat! ----- Method: NearEventual>>wait (in category 'waiting') ----- wait super waitTimeoutMSecs: 3. super wait. ^ self resolution.! ----- Method: NearEventual>>waitTimeoutMSecs: (in category 'waiting') ----- waitTimeoutMSecs: msecs super waitTimeoutMSecs: 3. super waitTimeoutMSecs: msecs. ^ self resolution.! ----- Method: NearEventual>>waitTimeoutSeconds: (in category 'waiting') ----- waitTimeoutSeconds: secs super waitTimeoutMSecs: 3. super waitTimeoutSeconds: secs. ^ self resolution.! AbstractEventual subclass: #Promise instanceVariableNames: 'vat msgBuffer resolver' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! !Promise commentStamp: 'tonyg 1/31/2018 23:34' prior: 0! I represent the result of an asynchronous message. Once the message is processed, I will be resolved to a value. I am typically instantiated by invocations of #futureSend:at:args: (and not by #futureDo:atArgs:). See class-comment of FutureNode. I also implement the Promises/A+ Javascript specification. This allows you to chain my instances to perform arbitrarily complex asynchronous tasks with error handling baked in. A Promise may be in one of three possible states: #pending, #fulfilled or #rejected. A Promise may move from #pending -> #fulfilled (by way of the resolveWith: message), or from #pending -> #rejected (by way of rejectWith:). No other state changes may occur. Once #fulfilled or #rejected, a Promise's value must not change. In keeping with the major Javascript Promise implementations' interpretations of this, calls to resolveWith: or rejectWith: when a Promise is in #fulfilled or #rejected state are simply ignored - an error is not signalled. (See test cases PromiseTest testFirstResolutionWins, testCannotRejectFulfilledPromise and testCannotResolveaRejectedPromise.)! ----- Method: Promise class>>ifRejected: (in category 'instance creation') ----- ifRejected: aBlock ^ self new whenRejected: aBlock; yourself. ! ----- Method: Promise class>>new (in category 'instance creation') ----- new ^ self newOnBuffer: (OrderedCollection new: 0) vat: self vat! ----- Method: Promise class>>newOnBuffer:vat: (in category 'instance creation') ----- newOnBuffer: buf vat: vat ^ self basicNew initializeOnBuffer: buf vat: vat; yourself! ----- Method: Promise class>>refDescriptionString (in category 'accessing') ----- refDescriptionString ^ 'promise'! ----- Method: Promise class>>unit: (in category 'instance creation') ----- unit: anObject "Return a resolved Promise. #new is the other half of Promise's unit function; #new returns an unresolved Promise." ^ Promise new resolveWith: anObject.! ----- Method: Promise>>error (in category 'accessing') ----- error ^ nil! ----- Method: Promise>>fulfillWith: (in category 'Promise/A+ protocol') ----- fulfillWith: aBlock self fulfillWith: aBlock passErrors: (msgBuffer collect: [:e | e isRejector]) isEmpty! ----- Method: Promise>>fulfillWith:passErrors: (in category 'Promise/A+ protocol') ----- fulfillWith: aBlock passErrors: aBoolean "Evaluate aBlock. If it signals an exception, reject this promise with the exception as the argument; if it returns a value [or another Promise], resolve this promise with the result. If aBoolean is true, and an exception is signaled, it is passed out to the caller. If aBoolean is false, signaled exceptions are considered handled after the promise has been rejected." [ self resolveWith: aBlock value ] on: Exception do: [ :ex | (ex isKindOf: Halt) ifTrue: [ex pass] ifFalse: [ self rejectWith: ex. aBoolean ifTrue: [ ex pass ] ]]! ----- Method: Promise>>ifRejected: (in category 'Promise/A+ protocol') ----- ifRejected: errBlock ^ errBlock ifNil: [^ self whenBroken: [:e | e]] ifNotNil: [:b | self whenBroken: errBlock]. ! ----- Method: Promise>>initializeOnBuffer:vat: (in category 'initialization') ----- initializeOnBuffer: buf vat: aVat super initialize. msgBuffer := buf. vat := aVat. resolver := self resolverClass onRef: self buffer: buf. ! ----- Method: Promise>>isEventual (in category 'testing') ----- isEventual ^ true! ----- Method: Promise>>isNear (in category 'testing') ----- isNear ^ false! ----- Method: Promise>>isPromise (in category 'testing') ----- isPromise ^ true! ----- Method: Promise>>isRejected (in category 'testing') ----- isRejected ^ false! ----- Method: Promise>>printOn: (in category 'printing') ----- printOn: stream stream nextPutAll: 'a Promise<'; nextPutAll: self class name; nextPutAll: '>::'; nextPutAll: self refDescriptionString; nextPutAll: '('. self vat printOn: stream. stream nextPutAll: ')'. ! ----- Method: Promise>>redirectEventualMessage: (in category 'Promise/A+ protocol') ----- redirectEventualMessage: anEventualMessage [msgBuffer addLast: anEventualMessage] on: Exception do: [:error | self redirectEventualMessage: anEventualMessage]. ! ----- Method: Promise>>reject (in category 'Promise/A+ protocol') ----- reject self rejectWith: nil! ----- Method: Promise>>rejectWith: (in category 'resolving') ----- rejectWith: reason self resolver smash: reason.! ----- Method: Promise>>resolve (in category 'Promise/A+ protocol') ----- resolve self resolveWith: nil! ----- Method: Promise>>resolveWith: (in category 'resolving') ----- resolveWith: arg "Resolve this promise. If arg is itself a Promise, make this promise depend upon it, as detailed in the Promises/A+ spec: https://promisesaplus.com/#the-promise-resolution-procedure" self resolver resolve: arg. ! ----- Method: Promise>>resolver (in category 'accessing') ----- resolver ^ resolver! ----- Method: Promise>>resolverClass (in category 'accessing') ----- resolverClass ^ self class resolverClass! ----- Method: Promise>>then: (in category 'Promise/A+ protocol') ----- then: resolvedBlock resolvedBlock ifNil: [^ self whenResolved: [:o | o]] ifNotNil: [:b | ^ self whenResolved: resolvedBlock].! ----- Method: Promise>>then:ifRejected: (in category 'Promise/A+ protocol') ----- then: resolvedBlock ifRejected: errBlock "Return a Promise that, if it resolves, runs the resolvedBlock. If resolution throws an Exception, it runs the errBlock." | p | p := self then: resolvedBlock. self ifRejected: errBlock. ^ p.! ----- Method: Promise>>value (in category 'accessing') ----- value ^ self! ----- Method: Promise>>vat (in category 'accessing') ----- vat vat isNil ifTrue: [vat := super vat]. ^ vat! ----- Method: Promise>>vat: (in category 'accessing') ----- vat: aVat vat := aVat! ----- Method: Promise>>whenMoreResolved: (in category 'when clause') ----- whenMoreResolved: reactor "aBlock numArgs <= 1 ifFalse: [self error: 'Must be 0- or 1-argument block']." self redirectMessageOneWay: (Message selector: #whenMoreResolved: argument: reactor). ! Object subclass: #ELib instanceVariableNames: '' classVariableNames: 'ForkDebugger' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: ELib class>>debugEventualException: (in category 'debugging') ----- debugEventualException: anException "For convenience. Construct a helper process to debug an exception that occurred in the active process later on so that the active process can (try to) resume. Uses a temporary variable to access and copy the signaler context now before it gets GC'ed." self forkDebugger ifTrue: [ | helperProcess | helperProcess := (EventualProcess forContext: anException signalerContext copyStack priority: Processor activeProcess priority onVat: Processor activeProcess vat) shouldResumeFromDebugger: true; yourself. Project current addDeferredUIMessage: [ helperProcess debugWithTitle: anException description full: false] ]. ! ----- Method: ELib class>>forkDebugger (in category 'preferences') ----- forkDebugger <preference: 'Fork Debugger on Exception' categoryList: #(promises) description: 'If enabled, any exception thrown inside the event loop will have its stack copied and a debugger will open outside of the event loop' type: #Boolean> ^ ForkDebugger ifNil: [false]! ----- Method: ELib class>>forkDebugger: (in category 'preferences') ----- forkDebugger: bool ForkDebugger := bool. ! ----- Method: Object>>basicEquality: (in category '*promiseslocal') ----- basicEquality: anObject "Answer whether the receiver and the argument represent the same object. If = is redefined in any subclass, consider also redefining the message hash." ^self == anObject! ----- Method: Object>>basicEquivalence: (in category '*promiseslocal') ----- basicEquivalence: anObject "Primitive. Answer whether the receiver and the argument are the same object (have the same object pointer). Do not redefine the message == in any other class!! Essential. No Lookup. Do not override in any subclass. See Object documentation whatIsAPrimitive." <primitive: 110> "primitiveEquivalent" self primitiveFailed! ----- Method: Object>>eventual (in category '*promiseslocal') ----- eventual ^ NearEventual newOn: self ! ----- Method: Object>>eventualInVat: (in category '*promiseslocal') ----- eventualInVat: aVat ^ NearEventual newOn: self vat: aVat ! ----- Method: Object>>whenBroken: (in category '*promiseslocal') ----- whenBroken: reactor | pair | pair := AbstractEventual promiseInVat: self vat. self whenMoreResolved: (WhenBrokenReactor onClosure: reactor ref: self resolver: pair value). ^ pair key ! ----- Method: Object>>whenBrokenOnly: (in category '*promiseslocal') ----- whenBrokenOnly: reactor self whenMoreResolved: (WhenBrokenReactor onClosure: reactor ref: self resolver: nil). ^ nil ! ----- Method: Object>>whenMoreResolved: (in category '*promiseslocal') ----- whenMoreResolved: reactor (reactor isEventual and: [reactor isRemote]) ifTrue: [ reactor redirectMessageOneWay: (Message selector: #value: argument: self value)] ifFalse: [reactor value: self value] ! ----- Method: Object>>whenRejected: (in category '*promiseslocal') ----- whenRejected: aBlock ^ self whenBroken: aBlock ! ----- Method: Object>>whenResolved: (in category '*promiseslocal') ----- whenResolved: reactor | pair | pair := AbstractEventual promiseInVat: self vat. self whenMoreResolved: (WhenResolvedReactor onClosure: reactor ref: self resolver: pair value). ^ pair key ! ----- Method: Object>>whenResolvedOnly: (in category '*promiseslocal') ----- whenResolvedOnly: reactor self whenMoreResolved: (WhenResolvedReactor onClosure: reactor ref: self resolver: nil). ^ nil! Object subclass: #PriorityVat instanceVariableNames: 'vatNick currentState normalQ immediateQ flashQ flashOverrideQ eventualProcess accessProtect readSynch' classVariableNames: 'LocalVat' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: PriorityVat class>>clearLocalVat (in category 'accessing') ----- clearLocalVat "PriorityVat clearLocalVat" ^ LocalVat ifNotNil: [LocalVat stop. LocalVat := nil] ! ----- Method: PriorityVat class>>localVat (in category 'accessing') ----- localVat "PriorityVat localVat" ^ LocalVat ifNil: [LocalVat := self newWithNick: 'local'] ! ----- Method: PriorityVat class>>newWithNick: (in category 'instance creation') ----- newWithNick: nick ^ self new vatNick: nick; yourself! ----- Method: PriorityVat class>>stateMap (in category 'class initialization') ----- stateMap "(((PriorityVat stateMap compile)))" | desc | desc := ProtocolStateCompiler initialState: #running. (desc newState: #running -> (nil -> #stopped)) add: #stopping -> (nil -> #stopping). (desc newState: #stopping -> (nil -> #stopped)) add: #stopping -> (nil -> #stopping); addInteger: #stopped -> (nil -> #stopped). (desc newState: #stopped -> (nil -> #stopped)). ^desc. ! ----- Method: PriorityVat>>initialize (in category 'private') ----- initialize self vatNick: '<new>'. self start. currentState := self class stateMap compile.! ----- Method: PriorityVat>>isRunning (in category 'action') ----- isRunning ^ currentState ifNil: [false] ifNotNil: [:state | state isStateNamed: #running].! ----- Method: PriorityVat>>nextPriorityMsg (in category 'private') ----- nextPriorityMsg readSynch wait. accessProtect critical: [ flashOverrideQ isEmpty ifFalse: [ ^ flashOverrideQ next ]. flashQ isEmpty ifFalse: [ ^ flashQ next ]. immediateQ isEmpty ifFalse: [ ^ immediateQ next ]. normalQ isEmpty ifFalse: [ ^ normalQ next ]. ^ nil].! ----- Method: PriorityVat>>postCopy (in category 'private') ----- postCopy super postCopy. self initialize.! ----- Method: PriorityVat>>printOn: (in category 'private') ----- printOn: stream stream nextPutAll: 'vat#'. stream nextPutAll: self vatNick. ! ----- Method: PriorityVat>>processSends (in category 'private') ----- processSends [[ Processor yield. self nextPriorityMsg ifNotNil: [:msg | msg value]. self isRunning ] whileTrue] ifCurtailed: [self isRunning ifTrue: [self restartEventLoop]]. ! ----- Method: PriorityVat>>restartEventLoop (in category 'action') ----- restartEventLoop | currentEventLoop | eventualProcess ifNotNil: [:ea | currentEventLoop := ea]. eventualProcess := nil. eventualProcess := EventualProcess newOnVat: self. eventualProcess resumeAsProcess. currentEventLoop ifNotNil: [:ea | ea terminate ].! ----- Method: PriorityVat>>schedule: (in category 'action') ----- schedule: msg self schedule: msg priority: #Normal. ! ----- Method: PriorityVat>>schedule:priority: (in category 'action') ----- schedule: msg priority: priority self isRunning ifFalse: [^ self]. accessProtect critical: [ (priority == 3 or: [priority == #FlashOverride]) ifTrue: [flashOverrideQ nextPut: msg]. (priority == 2 or: [priority == #Flash]) ifTrue: [flashQ nextPut: msg]. (priority == 1 or: [priority == #Immediate]) ifTrue: [immediateQ nextPut: msg]. (priority == 0 or: [priority == #Normal]) ifTrue: [normalQ nextPut: msg]]. readSynch signal. ! ----- Method: PriorityVat>>start (in category 'action') ----- start self isRunning ifTrue: [^ self]. normalQ := SharedQueue new. immediateQ := SharedQueue new. flashQ := SharedQueue new. flashOverrideQ := SharedQueue new. accessProtect := Semaphore forMutualExclusion. readSynch := Semaphore new. eventualProcess := EventualProcess newOnVat: self. eventualProcess resumeAsProcess. ! ----- Method: PriorityVat>>stop (in category 'action') ----- stop self transitionEvent: #stopping. self schedule: [#cycle]. (Delay forMilliseconds: 1) wait. eventualProcess ifNotNil: [:p | eventualProcess terminate]. eventualProcess := nil. normalQ := nil. immediateQ := nil. flashQ := nil. flashOverrideQ := nil. accessProtect := nil. readSynch := nil. ! ----- Method: PriorityVat>>stopped (in category 'action') ----- stopped self transitionEvent: #stopped. ! ----- Method: PriorityVat>>transitionEvent: (in category 'events') ----- transitionEvent: event | newState | newState := currentState transitionEvent: event value: event client: self. (newState ~= currentState) ifTrue: [ currentState := newState. ^ true] ifFalse: [^ false]! ----- Method: PriorityVat>>vatNick (in category 'accessing') ----- vatNick ^ vatNick! ----- Method: PriorityVat>>vatNick: (in category 'accessing') ----- vatNick: nick vatNick := nick. ! Object subclass: #PromiseWaiter instanceVariableNames: 'promise value state' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: PromiseWaiter class>>newOnPromise: (in category 'as yet unclassified') ----- newOnPromise: promise "Wait unconditionally for this promise to become fulfilled or rejected." ^ self new initializeOnPromise: promise; yourself. ! ----- Method: PromiseWaiter class>>waitOnPromise: (in category 'as yet unclassified') ----- waitOnPromise: promise "Wait unconditionally for this promise to become fulfilled or rejected." | waiter | waiter := PromiseWaiter newOnPromise: promise. ^ waiter wait. ! ----- Method: PromiseWaiter class>>waitTimeoutMSecs:onPromise: (in category 'as yet unclassified') ----- waitTimeoutMSecs: msecs onPromise: promise | waiter | waiter := PromiseWaiter newOnPromise: promise. ^ waiter waitTimeoutMSecs: msecs. ! ----- Method: PromiseWaiter class>>waitTimeoutSeconds:onPromise: (in category 'as yet unclassified') ----- waitTimeoutSeconds: secs onPromise: promise ^ self waitTimeoutMSecs: (secs * 1000) onPromise: promise! ----- Method: PromiseWaiter>>initializeOnPromise: (in category 'initialize-release') ----- initializeOnPromise: prom state := #pending. promise := prom. promise whenResolved: [:v | self result: v]. promise whenRejected: [:v | self result: v]. (promise isResolved or: [promise isRejected]) ifTrue: [self result: promise]. ! ----- Method: PromiseWaiter>>result: (in category 'accessing') ----- result: anObject "Set the value of result" (state == #fulfilled) ifTrue: [^self]. state := #fulfilled. ! ----- Method: PromiseWaiter>>wait (in category 'control') ----- wait "Wait unconditionally for this promise to become fulfilled or rejected." | sema | (state == #fulfilled) ifTrue: [ promise removeActionsWithReceiver: self. ^ promise value]. sema := Semaphore new. promise whenResolved: [sema signal]. [[sema wait] on: TestFailure do: [:e | ]] ensure: [promise removeActionsWithReceiver: self]. ^ promise value. ! ----- Method: PromiseWaiter>>waitTimeoutMSecs: (in category 'control') ----- waitTimeoutMSecs: timeout | sema delay | (state == #fulfilled) ifTrue: [ promise removeActionsWithReceiver: self. ^ promise resolution]. sema := Semaphore new. promise whenResolved: [sema signal]. delay := Delay timeoutSemaphore: sema afterMSecs: timeout. [sema wait] ensure: [ delay unschedule. promise removeActionsWithReceiver: self]. ^ promise resolution. ! ----- Method: PromiseWaiter>>waitTimeoutSeconds: (in category 'control') ----- waitTimeoutSeconds: seconds ^self waitTimeoutMSecs: seconds * 1000 ! Object subclass: #Reactor instanceVariableNames: 'ref resolver closure' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: Reactor class>>onClosure:ref:resolver: (in category 'instance creation') ----- onClosure: closure ref: ref resolver: resolver ^ self new initOnClosure: closure ref: ref resolver: resolver; yourself. ! ----- Method: Reactor>>initOnClosure:ref:resolver: (in category 'initialize-release') ----- initOnClosure: aClosure ref: aRef resolver: aResolver closure := aClosure. ref := aRef. resolver := aResolver. ! ----- Method: Reactor>>isRejector (in category 'testing') ----- isRejector ^ false! ----- Method: Reactor>>isResolver (in category 'testing') ----- isResolver ^ false! ----- Method: Reactor>>reactToLostClient: (in category 'reacting') ----- reactToLostClient: anException self value: anException. ^ nil! ----- Method: Reactor>>value: (in category 'reacting') ----- value: ignored closure isNil ifTrue:[^ nil]. ^ closure cull: ref value. ! Reactor subclass: #WhenBrokenReactor instanceVariableNames: '' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: WhenBrokenReactor class>>isPassByConstruction (in category 'serialization') ----- isPassByConstruction ^ true! ----- Method: WhenBrokenReactor>>isRejector (in category 'testing') ----- isRejector ^ true! ----- Method: WhenBrokenReactor>>value: (in category 'as yet unclassified') ----- value: ignored | aRef aResolver aClosure result | closure isNil ifTrue:[^ nil]. (ref isBroken) ifTrue: [ aRef := ref. aResolver := resolver. aClosure := closure. ref := nil. resolver := nil. closure := nil. [result := aClosure cull: aRef value] on: Error do: [:ex | result := ex]. aResolver notNil ifTrue: [ aResolver resolve: result]. ^ nil]. (ref isNear) ifTrue: [ ref := nil. resolver := nil. closure := nil. ^ nil]. (ref isResolved) ifTrue: [^ nil] ifFalse: [ref whenMoreResolved: self. ^ nil]. ! Reactor subclass: #WhenResolvedReactor instanceVariableNames: '' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: WhenResolvedReactor class>>isPassByConstruction (in category 'serialization') ----- isPassByConstruction ^ true! ----- Method: WhenResolvedReactor>>isResolver (in category 'testing') ----- isResolver ^ true! ----- Method: WhenResolvedReactor>>value: (in category 'as yet unclassified') ----- value: ignored | aRef aResolver aClosure result | closure isNil ifTrue:[^ nil]. (ref isResolved) ifTrue: [ aRef := ref. aResolver := resolver. aClosure := closure. ref := nil. resolver := nil. closure := nil. [result := aClosure cull: aRef value] on: Error do: [:ex | result := ex]. aResolver isNil ifFalse: [aResolver resolve: result]. ^ nil] ifFalse: [ ref whenMoreResolved: self. ^ nil]. ! Object subclass: #Resolver instanceVariableNames: '' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! Resolver subclass: #LocalResolver instanceVariableNames: 'ref buf' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: LocalResolver class>>onRef:buffer: (in category 'instance creation') ----- onRef: ref buffer: buf ^ self new initializeOnRef: ref buffer: buf; yourself ! ----- Method: LocalResolver>>initializeOnRef:buffer: (in category 'initialize-release') ----- initializeOnRef: aRef buffer: aBuf ref := aRef. buf := aBuf. ! ----- Method: LocalResolver>>isDone (in category 'resolving') ----- isDone ^ ref isNil ! ----- Method: LocalResolver>>resolve: (in category 'resolving') ----- resolve: resolutionValue | tmp1 | self isDone ifTrue: [ ^ PromiseAlreadyResolved new signal ]. tmp1 := AbstractEventual toReferenceContext: resolutionValue. ref becomeContext: tmp1. self sendMsgsToNewRef: ref. ref := nil. ^ nil ! ----- Method: LocalResolver>>sendMsgsToNewRef: (in category 'resolving') ----- sendMsgsToNewRef: newRef | pendingMessages msg | buf isNil ifTrue: [^nil]. pendingMessages := buf readStream. buf := nil. [pendingMessages atEnd] whileFalse: [ msg := pendingMessages next. newRef redirectEventualMessage: msg]. ! ----- Method: LocalResolver>>smash: (in category 'resolving') ----- smash: exception self isDone ifTrue: [ ^ PromiseAlreadyResolved new signal ]. ^ (AbstractEventual isReference: exception) ifTrue: [self resolve: exception] ifFalse: [ (exception class includesBehavior: Exception) ifTrue: [self resolve: exception] ifFalse: [self resolve: (BrokenEventual new exception: (BrokenPromiseValue value: exception); yourself)]]. ! ----- Method: Resolver>>isDone (in category 'resolving') ----- isDone self subclassResponsibility ! ----- Method: Resolver>>resolve: (in category 'resolving') ----- resolve: value self subclassResponsibility ! ----- Method: Resolver>>smash: (in category 'resolving') ----- smash: exception self subclassResponsibility ! ----- Method: Resolver>>smashString: (in category 'resolving') ----- smashString: exceptionTxt ^ self smash: (Error new messageText: exceptionTxt)! ServiceProvider subclass: #PromisesLocalServiceProvider instanceVariableNames: '' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: PromisesLocalServiceProvider class>>initialize (in category 'initialization') ----- initialize ServiceRegistry current buildProvider: self new! MessageSend subclass: #EventualMessageSend instanceVariableNames: 'resolver' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: EventualMessageSend class>>message: (in category 'instance creation') ----- message: aMessage ^ self new selector: aMessage selector; arguments: aMessage arguments; resolver: nil; yourself! ----- Method: EventualMessageSend class>>message:resolver: (in category 'instance creation') ----- message: aMessage resolver: aResolver ^ self new selector: aMessage selector; arguments: aMessage arguments; resolver: aResolver; yourself! ----- Method: EventualMessageSend class>>receiver:resolver:selector: (in category 'instance creation') ----- receiver: anObject resolver: aResolver selector: aSymbol ^ (super receiver: anObject selector: aSymbol) resolver: aResolver; yourself! ----- Method: EventualMessageSend class>>receiver:resolver:selector:arguments: (in category 'instance creation') ----- receiver: anObject resolver: aResolver selector: aSymbol arguments: anArray ^ (super receiver: anObject selector: aSymbol arguments: anArray) resolver: aResolver; yourself! ----- Method: EventualMessageSend class>>selector: (in category 'as yet unclassified') ----- selector: aSymbol ^ (super receiver: nil selector: aSymbol) resolver: nil; yourself! ----- Method: EventualMessageSend class>>selector:arguments: (in category 'as yet unclassified') ----- selector: aSymbol arguments: anArray ^ (super receiver: nil selector: aSymbol arguments: anArray) resolver: nil; yourself! ----- Method: EventualMessageSend class>>selector:arguments:resolver: (in category 'as yet unclassified') ----- selector: aSymbol arguments: anArray resolver: aResolver ^ (super receiver: nil selector: aSymbol arguments: anArray) resolver: aResolver; yourself! ----- Method: EventualMessageSend class>>selector:resolver: (in category 'as yet unclassified') ----- selector: aSymbol resolver: aResolver ^ (super receiver: nil selector: aSymbol) resolver: aResolver; yourself! ----- Method: EventualMessageSend>>isOneWay (in category 'testing') ----- isOneWay ^ self resolver isNil! ----- Method: EventualMessageSend>>isRejector (in category 'testing') ----- isRejector ^ (self selector == #whenMoreResolved:) and: [self arguments first isRejector]! ----- Method: EventualMessageSend>>printOn: (in category 'private') ----- printOn: t1 | t2 | t1 nextPutAll: 'EventualSend ('. receiver printOn: t1. t1 nextPutAll: ' '. (selector isUnary or: [selector isInfix]) ifTrue: [selector printOn: t1. t1 nextPutAll: ' '. self arguments do: [:t3 | t1 print: t3] separatedBy: [t1 nextPutAll: ' ']] ifFalse: [t2 := (self selector subStrings: ':') collect: [:t3 | t3 asSymbol asSimpleSetter asString]. t2 with: self arguments do: [:t3 :t4 | t1 nextPutAll: ' '; nextPutAll: t3; nextPutAll: ' '. t4 printOn: t1]]. t1 nextPutAll: ') -> ['. resolver printOn: t1. t1 nextPutAll: ']'! ----- Method: EventualMessageSend>>resolve: (in category 'api') ----- resolve: ref self resolver ifNotNil: [self resolver resolve: ref].! ----- Method: EventualMessageSend>>resolver (in category 'accessing') ----- resolver ^ resolver! ----- Method: EventualMessageSend>>resolver: (in category 'accessing') ----- resolver: aResolver resolver := aResolver! ----- Method: EventualMessageSend>>smash: (in category 'api') ----- smash: exception self resolver ifNotNil: [self resolver smash: exception].! ----- Method: EventualMessageSend>>value (in category 'api') ----- value | value | [ value := receiver perform: selector withArguments: (self collectArguments: arguments) inSuperclass: receiver class. self resolver notNil ifTrue: [ self resolver resolve: value ] ] on: Exception do: [:ex | self resolver ifNotNil: [:r | r smash: ex]. (ex isKindOf: Halt) ifTrue: [ex pass] ifFalse: [ELib debugEventualException: ex]]. ! Process subclass: #EventualProcess instanceVariableNames: 'eventualName vat' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: EventualProcess class>>forContext:priority:onVat: (in category 'instance creation') ----- forContext: aContext priority: anInteger onVat: aVat "Answer an instance of me that has suspended aContext at priority anInteger." | newProcess | newProcess := self newOnVat: aVat. newProcess suspendedContext: aContext. newProcess priority: anInteger. ^newProcess! ----- Method: EventualProcess class>>newOnVat: (in category 'instance creation') ----- newOnVat: vat ^ super new priority: Processor userBackgroundPriority; eventualName: 'vat thread'; vat: vat; setupContext; yourself! ----- Method: EventualProcess>>eventualName (in category 'accessing') ----- eventualName ^ eventualName! ----- Method: EventualProcess>>eventualName: (in category 'accessing') ----- eventualName: aName eventualName := aName. ! ----- Method: EventualProcess>>printOn: (in category 'accessing') ----- printOn: aStream aStream nextPutAll: '{squeake'. self eventualName notNil ifTrue: [ aStream nextPutAll: '-'. aStream nextPutAll: self eventualName asString]. aStream nextPutAll: '} '. super printOn: aStream. ! ----- Method: EventualProcess>>resume (in category 'changing process state') ----- resume (Processor activeProcess == self) ifTrue: [self resumeAsProcess] ifFalse: [self resumeInVat]. ! ----- Method: EventualProcess>>resumeAsProcess (in category 'changing process state') ----- resumeAsProcess super resume.! ----- Method: EventualProcess>>resumeInVat (in category 'changing process state') ----- resumeInVat self vat schedule: self suspendedContext.! ----- Method: EventualProcess>>setupContext (in category 'initialize-release') ----- setupContext self suspendedContext: [ self vat processSends. Processor terminateActive] asContext.! ----- Method: EventualProcess>>vat (in category 'accessing') ----- vat ^ vat! ----- Method: EventualProcess>>vat: (in category 'accessing') ----- vat: aVat vat := aVat! ----- Method: Process>>vat (in category '*promiseslocal') ----- vat ^ PriorityVat localVat.! ----- Method: BlockClosure>>eventual (in category '*promiseslocal') ----- eventual | pair eMsg | pair := AbstractEventual promiseInVat: self vat. eMsg := EventualMessageSend receiver: self resolver: pair value selector: #value. self vat schedule: eMsg. ^ pair key ! ----- Method: ProtoObject>>basicEquivalence: (in category '*promiseslocal') ----- basicEquivalence: anObject "Primitive. Answer whether the receiver and the argument are the same object (have the same object pointer). Do not redefine the message == in any other class!! Essential. No Lookup. Do not override in any subclass. See Object documentation whatIsAPrimitive." <primitive: 110> self primitiveFailed! ----- Method: ProtoObject>>defaultLabelForInspector (in category '*promiseslocal') ----- defaultLabelForInspector "Answer the default label to be used for an Inspector window on the receiver." ^ self class name! ----- Method: ProtoObject>>inspect (in category '*promiseslocal') ----- inspect "Create and schedule an Inspector in which the user can examine the receiver's variables." Inspector openOn: self withEvalPane: true! ----- Method: ProtoObject>>isBroken (in category '*promiseslocal') ----- isBroken ^ false! ----- Method: ProtoObject>>isEventual (in category '*promiseslocal') ----- isEventual ^ false ! ----- Method: ProtoObject>>isFulfilled (in category '*promiseslocal') ----- isFulfilled ^ self isNear ! ----- Method: ProtoObject>>isNear (in category '*promiseslocal') ----- isNear ^ true! ----- Method: ProtoObject>>isPromise (in category '*promiseslocal') ----- isPromise ^ false ! ----- Method: ProtoObject>>isProxy (in category '*promiseslocal') ----- isProxy ^ false ! ----- Method: ProtoObject>>isResolved (in category '*promiseslocal') ----- isResolved ^ self isPromise not ! ----- Method: ProtoObject>>redirectEventualMessage: (in category '*promiseslocal') ----- redirectEventualMessage: anEventualMessage anEventualMessage receiver: self. self vat schedule: anEventualMessage. ! ----- Method: ProtoObject>>resolution (in category '*promiseslocal') ----- resolution ^ self! ----- Method: ProtoObject>>vat (in category '*promiseslocal') ----- vat ^ Processor activeProcess vat ! TestCase subclass: #PriorityVatTest instanceVariableNames: 'eventReceived' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal-Testing'! ----- Method: PriorityVatTest>>tearDown (in category 'initialize-release') ----- tearDown (PriorityVat clearLocalVat; localVat) restartEventLoop. ! ----- Method: PriorityVatTest>>testPriorityVat (in category 'testing') ----- testPriorityVat | vat | vat := PriorityVat newWithNick: 'testVat'. eventReceived := false. vat schedule: [eventReceived := true]. (Delay forMilliseconds: 1) wait. self assert: eventReceived. vat stop.! TestCase subclass: #RefsTest instanceVariableNames: '' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal-Testing'! ----- Method: RefsTest>>tearDown (in category 'initialize-release') ----- tearDown (PriorityVat clearLocalVat; localVat) restartEventLoop. ! ----- Method: RefsTest>>testArithmeticPrimitivesWithPromiseReceiver (in category 'testing') ----- testArithmeticPrimitivesWithPromiseReceiver | t1 t2 | t1 := 42 eventual. t2 := 10. t1 * t2 whenResolved: [:t3 | self assert: t3 resolution == 420]! ----- Method: RefsTest>>testBasicPromiseResolution (in category 'testing') ----- testBasicPromiseResolution | pair | pair := AbstractEventual promise. self assert: pair key isEventual. pair value resolve: 'rob'. self assert: pair key isNear. self assert: pair key = 'rob'. ! ----- Method: RefsTest>>testBasicPromiseSmashing (in category 'testing') ----- testBasicPromiseSmashing | pair | pair := AbstractEventual promise. self assert: pair key isEventual. pair value smashString: 'test promise smashing'. self assert: pair key isBroken. self should: [pair key immediate] raise: Error! ----- Method: RefsTest>>testBasicPromiseToBooleanResolution (in category 'testing') ----- testBasicPromiseToBooleanResolution | tmp1 | tmp1 := AbstractEventual promise. self assert: tmp1 key isEventual. tmp1 value resolve: true. self assert: tmp1 key isNear; assert: tmp1 key = true! ----- Method: RefsTest>>testBlockClosure (in category 'testing') ----- testBlockClosure | result | [42 * 10] eventual whenResolved: [:r | result := r resolution]. (Delay forMilliseconds: 100) wait. self assert: result = 420.! ----- Method: RefsTest>>testFailureArithmeticPrimitivesWithPromiseArgument (in category 'testing') ----- testFailureArithmeticPrimitivesWithPromiseArgument | num1 num2 | num1 := 10. num2 := 42 eventual. [num1 * num2 whenResolved: [:result | self assert: result == 420]. self assert: false] on: Exception do: [:ex | ^ self assert: true]. self assert: false! ----- Method: RefsTest>>testLocalResolve (in category 'testing') ----- testLocalResolve | pair | pair := AbstractEventual promise. pair value resolve: 'rob'. self assert: (pair key = 'rob'). self should: [pair value smashString: 'test smash'] raise: Error. ! ----- Method: RefsTest>>testLocalSmash (in category 'testing') ----- testLocalSmash | pair | pair := AbstractEventual promise. pair value smashString: 'smash promise test'. self should: [pair key foobar] raise: Error. self should: [pair value smashString: 'smash promise test'] raise: Error! ----- Method: RefsTest>>testNearRefs (in category 'testing') ----- testNearRefs | obj | obj := Object new. self assert: (obj eventual = obj eventual). ! ----- Method: RefsTest>>testUsedLocalResolver (in category 'testing') ----- testUsedLocalResolver | resolver | resolver := LocalResolver onRef: nil buffer: nil. self assert: resolver isDone. self should: [resolver resolve: 2] raise: Error. self should: [resolver smashString: 'test smash'] raise: Error. ! ----- Method: RefsTest>>testWhenBroken (in category 'testing') ----- testWhenBroken | result oldForkDebugger | oldForkDebugger := ELib forkDebugger. ELib forkDebugger: false. 42 eventual / 0 whenBroken: [:t3 | result := t3 resolution. self assert: result isError]. (Delay forMilliseconds: 100) wait. self assert: (result class == ZeroDivide). ELib forkDebugger: oldForkDebugger. ! ----- Method: RefsTest>>testWhenResolved (in category 'testing') ----- testWhenResolved | result t1 t2 | t1 := 42 eventual. t2 := 10. t1 * t2 whenResolved: [:t3 | result := t3 resolution. self assert: result == 420]. (Delay forMilliseconds: 100) wait. self assert: result == 420.! Error subclass: #BrokenPromise instanceVariableNames: 'exception' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! !BrokenPromise commentStamp: 'tonyg 2/17/2017 13:53' prior: 0! I am signalled when, during a Promise>>wait, the promise is rejected. promise: the promise itself. ! ----- Method: BrokenPromise>>defaultAction (in category 'as yet unclassified') ----- defaultAction self messageText: 'Promise was rejected'. ^super defaultAction! ----- Method: BrokenPromise>>exception (in category 'as yet unclassified') ----- exception ^ exception! ----- Method: BrokenPromise>>exception: (in category 'as yet unclassified') ----- exception: aX exception := aX! ----- Method: BrokenPromise>>isResumable (in category 'as yet unclassified') ----- isResumable ^ true! ----- Method: BrokenPromise>>promise (in category 'as yet unclassified') ----- promise ^ self exception! Error subclass: #BrokenPromiseValue instanceVariableNames: 'value' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'! ----- Method: BrokenPromiseValue class>>value: (in category 'instance creation') ----- value: obj ^ self new value: obj; yourself! ----- Method: BrokenPromiseValue>>defaultAction (in category 'handling') ----- defaultAction self messageText: 'Promise was rejected with value: ', value. ^super defaultAction! ----- Method: BrokenPromiseValue>>isResumable (in category 'handling') ----- isResumable ^ true! ----- Method: BrokenPromiseValue>>value (in category 'accessing') ----- value ^ value.! ----- Method: BrokenPromiseValue>>value: (in category 'accessing') ----- value: anObject value := anObject.! Error subclass: #PromiseAlreadyResolved instanceVariableNames: '' classVariableNames: '' poolDictionaries: '' category: 'PromisesLocal'!

1 0

Re: [squeak-dev] Getting from GitBrowser to the System Browser
by Tom Beckmann 04 Oct '20

04 Oct '20

It looks like Jakob beat me by a couple of seconds :D Concerning the MCStReader error, have a look at this Inbox commit to fix it locally in your image for the moment :) http://forum.world.st/The-Inbox-Monticello-tobe-729-mcz-td5122924.html On Sun, Oct 4, 2020 at 3:14 PM Tom Beckmann <tomjonabc(a)gmail.com> wrote: > Hi timothy, > > first, on the Array>>\ error, this is likely because you somehow ended up > with the master instead of the squeak branch of squeak-tonel. I would > recommend to manually unload all three tonel packages using the Monticello > Browser and then running: > Metacello new > repository: 'github://squeak-smalltalk/squeak-tonel:squeak'; > baseline: 'Tonel'; > load. > > On Metacello vs Git and the general workflow: > - from my understanding, it is generally recommendable to first install a > package using Metacello as it takes care to resolve and install third-party > dependencies you may not want to care about > - Metacello is, however, end-user oriented if you will; the sources are > stored in a github-cache folder, which only exists for caching purposes. My > usual workflow is thus, after installing the desired package once using > Metacello, to clone the main repo (the repo that I actually care about) > again using the GitBrowser and do a checkout on the most recent commit on > master; this should leave things unchanged provided that Metacello also > installed the version from the master branch > - You can then work in your image and adapt things as needed; when you > have a working increment, you can use the GitBrowser again to create > commits and push them Github, typically to a fork that belongs to you and > then place a pull request > > You can skip Metacello if you clone all dependencies using the GitBrowser > and install them one after the other in the right order. If you look at the > many dependencies of for example Roassal [1], it will however be pretty > obvious why you would usually want to have Metacello automate this for you. > > Hope this helps you to get started. Please feel free to ask again if I > left something unanswered or if you feel like the workflow should be easier > in some way. Maybe there is something we can improve :) > > Best, > Tom > > [1] > https://github.com/tom95/Roassal3/blob/master/src/BaselineOfRoassal3/Baseli… > > On Sun, Oct 4, 2020 at 2:34 PM gettimothy via Squeak-dev < > squeak-dev(a)lists.squeakfoundation.org> wrote: > >> Hi folks, >> >> backing up from the specifics and looking at the "correct" way to go >> about this so we are all on the same page. >> >> Could you please check my assumptions as this Git stuff in squeak is new >> to me. >> >> >> If we have the Git, why do we need the Metacello? Can/should we do all >> the work in the Git and then when it is done, do the Metacello? >> >> >> Assuming "doing all the work in Git" is the way to go... >> >> Is just "working through the baseline" and getting things in the system a >> good approach? >> >> Thoughts? >> >> thx >> >> tty >> >> >>

2 2

getting squeak-launcher to git.
by gettimothy 04 Oct '20

04 Oct '20

Hi Jakob Marcel suggested This repository could be easily created: https://github.com/OpenSmalltalk/opensmalltalk-launcher Should I get this to my github account and then ask you folks to clone it? Also, I will need to get the changes we have made into a repo and I don't know how to do that on Pharo. Ideas? "No" is a good answer if you are too busy. cordially, t

2 2

Re: [squeak-dev] Getting from GitBrowser to the System Browser
by Tom Beckmann 04 Oct '20

04 Oct '20

Hi timothy, just as a quick update: the Baseline is now finally correct (I hadn't realized that my base package cannot share a prefix with the main package or else all its classes will be removed again when the main package loads). So, if you execute the following in a Squeak-trunk image and click "Proceed" a good number of times when you're prompted about missing classes, hopefully you'll be greeted with a chart: Metacello new baseline: 'Roassal3'; repository: 'github://tom95/Roassal3'; load. RSChartExample new example01Markers open. A note to my earlier description of the changes: I dropped the Roassal3-Shapes-Squeak package and instead put the changes directly in the Roassal3-Shapes package in a way that they remain compatible with Pharo. Best, Tom On Sat, Oct 3, 2020 at 11:40 PM gettimothy via Squeak-dev < squeak-dev(a)lists.squeakfoundation.org> wrote: > Tom thank you. > > I willhit it tomorrow! > > I am really looking forward to this port. > > Cheers. > > T > > > ---- On Sat, 03 Oct 2020 17:26:32 -0400 *tomjonabc(a)gmail.com > <tomjonabc(a)gmail.com> *wrote ---- > > Hi, > > Metacello new > baseline: 'Roassal3'; > repository: 'github://tom95/Roassal3'; > load. > > will get you started, then you will have to handle the various errors that > arise from the incorrect load order. Repeating the whole command once it's > done will allow you to recover from some load errors, too. > > Best, > Tom > > On Sat, Oct 3, 2020 at 10:21 PM gettimothy via Squeak-dev < > squeak-dev(a)lists.squeakfoundation.org> wrote: > > Hi Tom > > Thank you for the detailed reply. > > Re:"I would recommend using Metacello for loading it first, as it will > install all dependencies. " > > Where do I find that Metaccello? I assume I will need a > ConfigurationOfRoassal3 frome somewhere. > > Regarding the fork, I think yours us the way to go until I get the lay of > the land. > I haven't even wirked through roassak examples on pharo yet. > > When we get smooth installation abd Eliot has time to putter with it, the > community can decide on the Athens thing. > > Thanks again > > > > > ---- On Sat, 03 Oct 2020 15:57:43 -0400 *tomjonabc(a)gmail.com > <tomjonabc(a)gmail.com> * wrote ---- > > Hi timothy, > > the snippet from Jakob should give you the updated Tonel such that you can > load Roassal and its dependencies, at least syntax/format-wise. I would > recommend using Metacello for loading it first, as it will install all > dependencies. If you use my fork, you will get the "repaired" Geometry > package. Afterwards, you can use the GitBrowser for proper development by > cloning my Roassal fork and then checking out the code. Note that you will > hit a great number of missing dependencies, which you need to all "Proceed" > and potentially also fix manually. Some code may not be properly > overridden, so be sure to check the -Squeak packages for missing overrides > if you hit an error in a specific method. I'm hoping to get around to > investigate the proper Baseline load order sometime in the next few days > (especially also for my own curiosity...). > > Concerning next steps for porting: you can base your work off of my fork > (for example simply fork it again and if you like, place pull requests). Or > alternatively, take a different route to porting, potentially keeping > Athens, and base your own work on the Roassal main repo. > > I'll provide a quick description of the things in my fork in the > following. There are three packages with adaptations for Squeak (of which > the naming can be improved): > - Roassal3-Pharo-Squeak: some classes from the Pharo Base System that > Roassal assumes exist. For a proper port, I would want to get rid of this > entirely and instead introduce adapter where necessary. This has to be > loaded first as Roassal3 (core) wants to extend these classes, too. > - Roassal3-Squeak: this is the proper port, mostly the Balloon code for > rendering and for our Morph. > - Roassal3-Shapes-Squeak: the -Shapes package uses some functions from the > font system. We need to override these. We can't put these in our other > -Squeak package because we first need the other classes to be loaded. > > Important todo items that I can currently see: > - only the basic packages work (I tested Charts in particular); others > have different dependencies into the Pharo system (e.g. UML) > - quality and performance are lacking when compared to the Cairo/Athens > version > - fonts do not scale currently > > Best, > Tom > > On Sat, Oct 3, 2020 at 8:41 PM gettimothy via Squeak-dev < > squeak-dev(a)lists.squeakfoundation.org> wrote: > > Hi, > > Thanks. > > On a brand new squeak6.0 alpha (easily spun up thanks to the > squeak-launcher (:) > git tools, etc installed via the preference wizard. > BaselineOftonel is in Monticello browser. > > I run > > repository: 'github://squeak-smalltalk/squeak-tonel:squeak'; > baseline: 'Tonel'; > get; load. > > works fine. > > Open the Git browser, > > Add Roassal3 project. > > RHClick..Add remote copy-n-paste in > <https://github.com/gettimothy/hello-world.git> > https://github.com/tom95/Roassal3 > > > MNU Text(Object) does not understand #includesSubstring: > > what am I missing? > > thx > > > > The MNU again on > ---- On Sat, 03 Oct 2020 13:15:11 -0400 *Jakob Reschke > <forums.jakob(a)resfarm.de <forums.jakob(a)resfarm.de>>* wrote ---- > > Hi, > > Tom provided the fix and the pull request, and I integrated it. So > yes, we work together. > > Now to update an existing installation I suppose one should use Metacello: > > Metacello new > repository: 'github://squeak-smalltalk/squeak-tonel:squeak'; > baseline: 'Tonel'; > get; load. > > Kind regards, > Jakob > > Am Sa., 3. Okt. 2020 um 18:26 Uhr schrieb gettimothy <gettimothy(a)zoho.com>: > > > > > > > Tom, > > > > Thank you very much for your work. > > > > Is this in support of Jakob's pull request? i.e. are you two working > together? > > > > How should I proceed from here? Pull from your repo? > > > > > > cheers, > > > > t > > > > > > ---- On Sat, 03 Oct 2020 10:49:20 -0400 Tom Beckmann < > tomjonabc(a)gmail.com> wrote ---- > > > > Hi timothy, > > (you'll probably be seeing this mail twice, my first attempt bounced on > the ML because my mail address had changed, sorry!) > > > > after I read yours and Eliot's conversation, I went to try loading > Roassal3 to see how our Tonel support is doing. I stumbled over three > errors: > > - The error you just mentioned [1] > > - Monticello was not strict enough with matching MCReader capabilities > [2] > > - The Geometry package used in Roassal uses Unicode symbols in their > code, which is not supported in Squeak [3] > > > > I then went ahead and tried to adapt things a little and got the result > you can see in the attachment. The experiment is found here [4]. I decided > to not load Athena at all and started putting together an alternative > Balloon backend instead (I am aware that Athena has a Balloon backend as > well, the one I found consisted mostly of stubs, however). The resulting > quality does not compare with Cairo, of course, but the basics were up and > running very quickly. > > > > In theory, this should give you the working installation, however, > packages load out-of-order because I did not manage to the baseline quite > right just yet: > > > > Metacello new > > baseline: 'Roassal3'; > > repository: 'github://tom95/Roassal3'; > > load. > > > > Best, > > Tom > > > > [1] https://github.com/squeak-smalltalk/squeak-tonel/pull/5 > > [2] > http://forum.world.st/The-Inbox-Monticello-tobe-729-mcz-td5122924.html > > [3] > https://github.com/tom95/Geometry/commit/5e7e1fa89bbd699baf41066e33d6242730… > > [4] https://github.com/tom95/Roassal3 > > > > On Sat, Oct 3, 2020 at 4:38 PM gettimothy via Squeak-dev < > squeak-dev(a)lists.squeakfoundation.org> wrote: > > > > > > Thank you. > > > > > > If you are interested, I will be figuring out Pillar with this github > stuff and getting the beginnings of some books up on squeakbooks.org* > > > > I will be documenting these steps in a booklet. > > > > This squot/git stuff will both be used and the subject of that booklet. > > > > good stuff. > > > > thanks for your work. > > > > > > > > > > *Help Browser team...I am confident that an XTreams-Parsing grammar > /actor pair can be written to auto-generate HelpBrowser books from the > Pillar to the Help Browser. > > > > > > > > > > > > > > ---- On Sat, 03 Oct 2020 10:32:02 -0400 Jakob Reschke < > forums.jakob(a)resfarm.de> wrote ---- > > > > I am in the middle of integrating a pull request to solve this bug in > > squeak-tonel. :-) > > > > > > > > -- > > Sent from: http://forum.world.st/Squeak-Dev-f45488.html > > > > > > > > > > > > > > > > > > >

2 2

GitReference class >> validateReferenceName
by gettimothy 04 Oct '20

04 Oct '20

Hi folks, messing about with the new-fangled git stuff. I am 'Add Git remote" thing , click 'ok' and MNU on Text >>includesSubstring. I replace aName (which is a Text) with aName string and all works as expected. validateReferenceName: aName "See https://git-scm.com/docs/git-check-ref-format" | tokens illegalCharacters | illegalCharacters := '[?+~^\*: '. (aName includesAnyOf: illegalCharacters) ifTrue: [ GitInvalidReferenceName signal: 'A reference name can not include whitespace or any of the following characters: ' , illegalCharacters.]. aName isEmpty ifTrue: [GitInvalidReferenceName signal: 'A reference name can not be empty']. (aName string includesSubstring: '..') ifTrue: [GitInvalidReferenceName signal: 'A reference name can not include the string ''..''']. (aName string ncludesSubstring: '@{') ifTrue: [GitInvalidReferenceName signal: 'A reference name can not include the string ''@{''']. (aName string includesSubstring: '//') ifTrue: [GitInvalidReferenceName signal: 'A reference name can not include two consecutive slashes']. (aName string first = $/ or: [aName last = $/]) ifTrue: [GitInvalidReferenceName signal: 'A reference name can not start or end with a slash']. (aName string endsWith: '@') ifTrue: [GitInvalidReferenceName signal: '''@'' is not a valid reference name']. tokens := aName string findTokens: '/'. (tokens anySatisfy: [:t | (t first = $.) or: [t endsWith: '.lock']]) ifTrue: [ GitInvalidReferenceName signal: 'A reference component can not start with a dot or end with .lock']. hth. btw, books in pillar format (?) for squeakbooks.org/com will be hosted on github eventually and then hopefully auto-published on the website. hence, the git-tools stuff work.

2 2

Re: [squeak-dev] Getting from GitBrowser to the System Browser
by Tom Beckmann 03 Oct '20

03 Oct '20

Hi, Metacello new baseline: 'Roassal3'; repository: 'github://tom95/Roassal3'; load. will get you started, then you will have to handle the various errors that arise from the incorrect load order. Repeating the whole command once it's done will allow you to recover from some load errors, too. Best, Tom On Sat, Oct 3, 2020 at 10:21 PM gettimothy via Squeak-dev < squeak-dev(a)lists.squeakfoundation.org> wrote: > Hi Tom > > Thank you for the detailed reply. > > Re:"I would recommend using Metacello for loading it first, as it will > install all dependencies. " > > Where do I find that Metaccello? I assume I will need a > ConfigurationOfRoassal3 frome somewhere. > > Regarding the fork, I think yours us the way to go until I get the lay of > the land. > I haven't even wirked through roassak examples on pharo yet. > > When we get smooth installation abd Eliot has time to putter with it, the > community can decide on the Athens thing. > > Thanks again > > > > > ---- On Sat, 03 Oct 2020 15:57:43 -0400 *tomjonabc(a)gmail.com > <tomjonabc(a)gmail.com> * wrote ---- > > Hi timothy, > > the snippet from Jakob should give you the updated Tonel such that you can > load Roassal and its dependencies, at least syntax/format-wise. I would > recommend using Metacello for loading it first, as it will install all > dependencies. If you use my fork, you will get the "repaired" Geometry > package. Afterwards, you can use the GitBrowser for proper development by > cloning my Roassal fork and then checking out the code. Note that you will > hit a great number of missing dependencies, which you need to all "Proceed" > and potentially also fix manually. Some code may not be properly > overridden, so be sure to check the -Squeak packages for missing overrides > if you hit an error in a specific method. I'm hoping to get around to > investigate the proper Baseline load order sometime in the next few days > (especially also for my own curiosity...). > > Concerning next steps for porting: you can base your work off of my fork > (for example simply fork it again and if you like, place pull requests). Or > alternatively, take a different route to porting, potentially keeping > Athens, and base your own work on the Roassal main repo. > > I'll provide a quick description of the things in my fork in the > following. There are three packages with adaptations for Squeak (of which > the naming can be improved): > - Roassal3-Pharo-Squeak: some classes from the Pharo Base System that > Roassal assumes exist. For a proper port, I would want to get rid of this > entirely and instead introduce adapter where necessary. This has to be > loaded first as Roassal3 (core) wants to extend these classes, too. > - Roassal3-Squeak: this is the proper port, mostly the Balloon code for > rendering and for our Morph. > - Roassal3-Shapes-Squeak: the -Shapes package uses some functions from the > font system. We need to override these. We can't put these in our other > -Squeak package because we first need the other classes to be loaded. > > Important todo items that I can currently see: > - only the basic packages work (I tested Charts in particular); others > have different dependencies into the Pharo system (e.g. UML) > - quality and performance are lacking when compared to the Cairo/Athens > version > - fonts do not scale currently > > Best, > Tom > > On Sat, Oct 3, 2020 at 8:41 PM gettimothy via Squeak-dev < > squeak-dev(a)lists.squeakfoundation.org> wrote: > > Hi, > > Thanks. > > On a brand new squeak6.0 alpha (easily spun up thanks to the > squeak-launcher (:) > git tools, etc installed via the preference wizard. > BaselineOftonel is in Monticello browser. > > I run > > repository: 'github://squeak-smalltalk/squeak-tonel:squeak'; > baseline: 'Tonel'; > get; load. > > works fine. > > Open the Git browser, > > Add Roassal3 project. > > RHClick..Add remote copy-n-paste in > <https://github.com/gettimothy/hello-world.git> > https://github.com/tom95/Roassal3 > > > MNU Text(Object) does not understand #includesSubstring: > > what am I missing? > > thx > > > > The MNU again on > ---- On Sat, 03 Oct 2020 13:15:11 -0400 *Jakob Reschke > <forums.jakob(a)resfarm.de <forums.jakob(a)resfarm.de>>* wrote ---- > > Hi, > > Tom provided the fix and the pull request, and I integrated it. So > yes, we work together. > > Now to update an existing installation I suppose one should use Metacello: > > Metacello new > repository: 'github://squeak-smalltalk/squeak-tonel:squeak'; > baseline: 'Tonel'; > get; load. > > Kind regards, > Jakob > > Am Sa., 3. Okt. 2020 um 18:26 Uhr schrieb gettimothy <gettimothy(a)zoho.com>: > > > > > > > Tom, > > > > Thank you very much for your work. > > > > Is this in support of Jakob's pull request? i.e. are you two working > together? > > > > How should I proceed from here? Pull from your repo? > > > > > > cheers, > > > > t > > > > > > ---- On Sat, 03 Oct 2020 10:49:20 -0400 Tom Beckmann < > tomjonabc(a)gmail.com> wrote ---- > > > > Hi timothy, > > (you'll probably be seeing this mail twice, my first attempt bounced on > the ML because my mail address had changed, sorry!) > > > > after I read yours and Eliot's conversation, I went to try loading > Roassal3 to see how our Tonel support is doing. I stumbled over three > errors: > > - The error you just mentioned [1] > > - Monticello was not strict enough with matching MCReader capabilities > [2] > > - The Geometry package used in Roassal uses Unicode symbols in their > code, which is not supported in Squeak [3] > > > > I then went ahead and tried to adapt things a little and got the result > you can see in the attachment. The experiment is found here [4]. I decided > to not load Athena at all and started putting together an alternative > Balloon backend instead (I am aware that Athena has a Balloon backend as > well, the one I found consisted mostly of stubs, however). The resulting > quality does not compare with Cairo, of course, but the basics were up and > running very quickly. > > > > In theory, this should give you the working installation, however, > packages load out-of-order because I did not manage to the baseline quite > right just yet: > > > > Metacello new > > baseline: 'Roassal3'; > > repository: 'github://tom95/Roassal3'; > > load. > > > > Best, > > Tom > > > > [1] https://github.com/squeak-smalltalk/squeak-tonel/pull/5 > > [2] > http://forum.world.st/The-Inbox-Monticello-tobe-729-mcz-td5122924.html > > [3] > https://github.com/tom95/Geometry/commit/5e7e1fa89bbd699baf41066e33d6242730… > > [4] https://github.com/tom95/Roassal3 > > > > On Sat, Oct 3, 2020 at 4:38 PM gettimothy via Squeak-dev < > squeak-dev(a)lists.squeakfoundation.org> wrote: > > > > > > Thank you. > > > > > > If you are interested, I will be figuring out Pillar with this github > stuff and getting the beginnings of some books up on squeakbooks.org* > > > > I will be documenting these steps in a booklet. > > > > This squot/git stuff will both be used and the subject of that booklet. > > > > good stuff. > > > > thanks for your work. > > > > > > > > > > *Help Browser team...I am confident that an XTreams-Parsing grammar > /actor pair can be written to auto-generate HelpBrowser books from the > Pillar to the Help Browser. > > > > > > > > > > > > > > ---- On Sat, 03 Oct 2020 10:32:02 -0400 Jakob Reschke < > forums.jakob(a)resfarm.de> wrote ---- > > > > I am in the middle of integrating a pull request to solve this bug in > > squeak-tonel. :-) > > > > > > > > -- > > Sent from: http://forum.world.st/Squeak-Dev-f45488.html > > > > > > > > > > > > > > > > > >

2 1

Re: [squeak-dev] Getting from GitBrowser to the System Browser
by Tom Beckmann 03 Oct '20

03 Oct '20

Hi timothy, the snippet from Jakob should give you the updated Tonel such that you can load Roassal and its dependencies, at least syntax/format-wise. I would recommend using Metacello for loading it first, as it will install all dependencies. If you use my fork, you will get the "repaired" Geometry package. Afterwards, you can use the GitBrowser for proper development by cloning my Roassal fork and then checking out the code. Note that you will hit a great number of missing dependencies, which you need to all "Proceed" and potentially also fix manually. Some code may not be properly overridden, so be sure to check the -Squeak packages for missing overrides if you hit an error in a specific method. I'm hoping to get around to investigate the proper Baseline load order sometime in the next few days (especially also for my own curiosity...). Concerning next steps for porting: you can base your work off of my fork (for example simply fork it again and if you like, place pull requests). Or alternatively, take a different route to porting, potentially keeping Athens, and base your own work on the Roassal main repo. I'll provide a quick description of the things in my fork in the following. There are three packages with adaptations for Squeak (of which the naming can be improved): - Roassal3-Pharo-Squeak: some classes from the Pharo Base System that Roassal assumes exist. For a proper port, I would want to get rid of this entirely and instead introduce adapter where necessary. This has to be loaded first as Roassal3 (core) wants to extend these classes, too. - Roassal3-Squeak: this is the proper port, mostly the Balloon code for rendering and for our Morph. - Roassal3-Shapes-Squeak: the -Shapes package uses some functions from the font system. We need to override these. We can't put these in our other -Squeak package because we first need the other classes to be loaded. Important todo items that I can currently see: - only the basic packages work (I tested Charts in particular); others have different dependencies into the Pharo system (e.g. UML) - quality and performance are lacking when compared to the Cairo/Athens version - fonts do not scale currently Best, Tom On Sat, Oct 3, 2020 at 8:41 PM gettimothy via Squeak-dev < squeak-dev(a)lists.squeakfoundation.org> wrote: > Hi, > > Thanks. > > On a brand new squeak6.0 alpha (easily spun up thanks to the > squeak-launcher (:) > git tools, etc installed via the preference wizard. > BaselineOftonel is in Monticello browser. > > I run > > repository: 'github://squeak-smalltalk/squeak-tonel:squeak'; > baseline: 'Tonel'; > get; load. > > works fine. > > Open the Git browser, > > Add Roassal3 project. > > RHClick..Add remote copy-n-paste in > <https://github.com/gettimothy/hello-world.git> > https://github.com/tom95/Roassal3 > > > MNU Text(Object) does not understand #includesSubstring: > > what am I missing? > > thx > > > > The MNU again on > ---- On Sat, 03 Oct 2020 13:15:11 -0400 *Jakob Reschke > <forums.jakob(a)resfarm.de <forums.jakob(a)resfarm.de>>* wrote ---- > > Hi, > > Tom provided the fix and the pull request, and I integrated it. So > yes, we work together. > > Now to update an existing installation I suppose one should use Metacello: > > Metacello new > repository: 'github://squeak-smalltalk/squeak-tonel:squeak'; > baseline: 'Tonel'; > get; load. > > Kind regards, > Jakob > > Am Sa., 3. Okt. 2020 um 18:26 Uhr schrieb gettimothy <gettimothy(a)zoho.com>: > > > > > > > Tom, > > > > Thank you very much for your work. > > > > Is this in support of Jakob's pull request? i.e. are you two working > together? > > > > How should I proceed from here? Pull from your repo? > > > > > > cheers, > > > > t > > > > > > ---- On Sat, 03 Oct 2020 10:49:20 -0400 Tom Beckmann < > tomjonabc(a)gmail.com> wrote ---- > > > > Hi timothy, > > (you'll probably be seeing this mail twice, my first attempt bounced on > the ML because my mail address had changed, sorry!) > > > > after I read yours and Eliot's conversation, I went to try loading > Roassal3 to see how our Tonel support is doing. I stumbled over three > errors: > > - The error you just mentioned [1] > > - Monticello was not strict enough with matching MCReader capabilities > [2] > > - The Geometry package used in Roassal uses Unicode symbols in their > code, which is not supported in Squeak [3] > > > > I then went ahead and tried to adapt things a little and got the result > you can see in the attachment. The experiment is found here [4]. I decided > to not load Athena at all and started putting together an alternative > Balloon backend instead (I am aware that Athena has a Balloon backend as > well, the one I found consisted mostly of stubs, however). The resulting > quality does not compare with Cairo, of course, but the basics were up and > running very quickly. > > > > In theory, this should give you the working installation, however, > packages load out-of-order because I did not manage to the baseline quite > right just yet: > > > > Metacello new > > baseline: 'Roassal3'; > > repository: 'github://tom95/Roassal3'; > > load. > > > > Best, > > Tom > > > > [1] https://github.com/squeak-smalltalk/squeak-tonel/pull/5 > > [2] > http://forum.world.st/The-Inbox-Monticello-tobe-729-mcz-td5122924.html > > [3] > https://github.com/tom95/Geometry/commit/5e7e1fa89bbd699baf41066e33d6242730… > > [4] https://github.com/tom95/Roassal3 > > > > On Sat, Oct 3, 2020 at 4:38 PM gettimothy via Squeak-dev < > squeak-dev(a)lists.squeakfoundation.org> wrote: > > > > > > Thank you. > > > > > > If you are interested, I will be figuring out Pillar with this github > stuff and getting the beginnings of some books up on squeakbooks.org* > > > > I will be documenting these steps in a booklet. > > > > This squot/git stuff will both be used and the subject of that booklet. > > > > good stuff. > > > > thanks for your work. > > > > > > > > > > *Help Browser team...I am confident that an XTreams-Parsing grammar > /actor pair can be written to auto-generate HelpBrowser books from the > Pillar to the Help Browser. > > > > > > > > > > > > > > ---- On Sat, 03 Oct 2020 10:32:02 -0400 Jakob Reschke < > forums.jakob(a)resfarm.de> wrote ---- > > > > I am in the middle of integrating a pull request to solve this bug in > > squeak-tonel. :-) > > > > > > > > -- > > Sent from: http://forum.world.st/Squeak-Dev-f45488.html > > > > > > > > > > > > > > > > >

2 1

Re: [squeak-dev] Getting from GitBrowser to the System Browser
by Tom Beckmann 03 Oct '20

03 Oct '20

Hi timothy, (you'll probably be seeing this mail twice, my first attempt bounced on the ML because my mail address had changed, sorry!) after I read yours and Eliot's conversation, I went to try loading Roassal3 to see how our Tonel support is doing. I stumbled over three errors: - The error you just mentioned [1] - Monticello was not strict enough with matching MCReader capabilities [2] - The Geometry package used in Roassal uses Unicode symbols in their code, which is not supported in Squeak [3] I then went ahead and tried to adapt things a little and got the result you can see in the attachment. The experiment is found here [4]. I decided to not load Athena at all and started putting together an alternative Balloon backend instead (I am aware that Athena has a Balloon backend as well, the one I found consisted mostly of stubs, however). The resulting quality does not compare with Cairo, of course, but the basics were up and running very quickly. In theory, this should give you the working installation, however, packages load out-of-order because I did not manage to the baseline quite right just yet: Metacello new baseline: 'Roassal3'; repository: 'github://tom95/Roassal3'; load. Best, Tom [1] https://github.com/squeak-smalltalk/squeak-tonel/pull/5 [2] http://forum.world.st/The-Inbox-Monticello-tobe-729-mcz-td5122924.html [3] https://github.com/tom95/Geometry/commit/5e7e1fa89bbd699baf41066e33d6242730… [4] https://github.com/tom95/Roassal3 On Sat, Oct 3, 2020 at 4:38 PM gettimothy via Squeak-dev < squeak-dev(a)lists.squeakfoundation.org> wrote: > > Thank you. > > > If you are interested, I will be figuring out Pillar with this github > stuff and getting the beginnings of some books up on squeakbooks.org* > > I will be documenting these steps in a booklet. > > This squot/git stuff will both be used and the subject of that booklet. > > good stuff. > > thanks for your work. > > > > > *Help Browser team...I am confident that an XTreams-Parsing grammar /actor > pair can be written to auto-generate HelpBrowser books from the Pillar to > the Help Browser. > > > > > > > ---- On Sat, 03 Oct 2020 10:32:02 -0400 *Jakob Reschke > <forums.jakob(a)resfarm.de <forums.jakob(a)resfarm.de>>* wrote ---- > > I am in the middle of integrating a pull request to solve this bug in > squeak-tonel. :-) > > > > -- > Sent from: http://forum.world.st/Squeak-Dev-f45488.html > > > >

3 3

Getting from GitBrowser to the System Browser
by gettimothy 03 Oct '20

03 Oct '20

Hi folks, I am trying to get the Roassal stuff into Squeak. https://github.com/ObjectProfile/Roassal3 The GitBrowser has succesfully pulled it, I have several branches to choose from and I want to get the stuff into Squeak browser and tests tool. Anybody know how to proceed? thx

2 5

← Newer
1
...
33
34
35
36
37
38
39
40
Older →

Jump to page: