Packages May 2013

packages@lists.squeakfoundation.org

1 participants
357 discussions

The Trunk: Collections-nice.520.mcz
by commits＠source.squeak.org 31 May '13

31 May '13

Nicolas Cellier uploaded a new version of Collections to project The Trunk: http://source.squeak.org/trunk/Collections-nice.520.mcz ==================== Summary ==================== Name: Collections-nice.520 Author: nice Time: 31 May 2013, 12:23:43.567 am UUID: 6ef25398-faee-45ff-a409-52d3f36d98c8 Ancestors: Collections-fbs.519 Introduce Character null =============== Diff against Collections-fbs.519 =============== Item was changed: ----- Method: Character class>>constantNames (in category 'private') ----- constantNames + ^ #( backspace cr delete escape lf null newPage space tab ).! - ^ #( backspace cr delete escape lf newPage space tab ).! Item was added: + ----- Method: Character class>>null (in category 'accessing untypeable characters') ----- + null + ^ self value: 0! Item was changed: ----- Method: NullStream>>element (in category 'accessing') ----- element "The element returned by the stream" + ^binary ifTrue:[0] ifFalse:[Character null]! - ^binary ifTrue:[0] ifFalse:[Character value: 0]! Item was changed: ----- Method: String>>compressWithTable: (in category 'converting') ----- compressWithTable: tokens "Return a string with all substrings that occur in tokens replaced by a character with ascii code = 127 + token index. This will work best if tokens are sorted by size. Assumes this string contains no characters > 127, or that they are intentionally there and will not interfere with this process." | str null finalSize result ri c | + null := Character null. - null := Character value: 0. str := self copyFrom: 1 to: self size. "Working string will get altered" finalSize := str size. tokens doWithIndex: [:token :tIndex | | start ts | start := 1. [(start := str findString: token startingAt: start) > 0] whileTrue: [ts := token size. ((start + ts) <= str size and: [(str at: start + ts) = $ and: [tIndex*2 <= 128]]) ifTrue: [ts := token size + 1. "include training blank" str at: start put: (Character value: tIndex*2 + 127)] ifFalse: [str at: start put: (Character value: tIndex + 127)]. str at: start put: (Character value: tIndex + 127). 1 to: ts-1 do: [:i | str at: start+i put: null]. finalSize := finalSize - (ts - 1). start := start + ts]]. result := String new: finalSize. ri := 0. 1 to: str size do: [:i | (c := str at: i) = null ifFalse: [result at: (ri := ri+1) put: c]]. ^ result!

1 0

The Trunk: Collections-nice.520.mcz
by commits＠source.squeak.org 31 May '13

31 May '13

1 0

The Trunk: KernelTests-fbs.252.mcz
by commits＠source.squeak.org 31 May '13

31 May '13

Frank Shearar uploaded a new version of KernelTests to project The Trunk: http://source.squeak.org/trunk/KernelTests-fbs.252.mcz ==================== Summary ==================== Name: KernelTests-fbs.252 Author: fbs Time: 30 May 2013, 11:08:47.493 pm UUID: 8b9b74b0-07df-4001-a33a-046e1f0e348e Ancestors: KernelTests-fbs.251 Turn Promise into a fully chainable object with decent error handling. (This implements the Smalltalk equivalent of JavaScript's Promises/A+ specification.) =============== Diff against KernelTests-fbs.251 =============== Item was added: + Object subclass: #NullMutex + instanceVariableNames: 'semaphore owner' + classVariableNames: '' + poolDictionaries: '' + category: 'KernelTests-Processes'! + + !NullMutex commentStamp: 'fbs 5/17/2013 20:30' prior: 0! + A Mutex is a light-weight MUTual EXclusion object being used when two or more processes need to access a shared resource concurrently. A Mutex grants ownership to a single process and will suspend any other process trying to aquire the mutex while in use. Waiting processes are granted access to the mutex in the order the access was requested. + + This Mutex DOES NOT mutually exclude anything. It just implements the same protocol.! Item was added: + ----- Method: NullMutex>>critical: (in category 'mutual exclusion') ----- + critical: aBlock + ^ aBlock value.! Item was added: + ----- Method: Promise>>unsynchronized (in category '*KernelTests-Processes') ----- + unsynchronized + "This is useful for tests, because it's quite easy otherwise to deadlock your image. It is a DISASTER to use this in production code!!" + mutex := NullMutex new.! Item was added: + ----- Method: PromiseTest>>testAnErrorInThenRejectsPromise (in category 'testing - monad') ----- + testAnErrorInThenRejectsPromise + | p q | + p := Promise new. + q := p then: [:v | KeyNotFound signal]. + p resolveWith: 1. + self deny: p isRejected description: 'Original Promise rejected'. + self assert: q isRejected description: 'Broken Promise not rejected'.! Item was added: + ----- Method: PromiseTest>>testCanRejectPromise (in category 'testing - monad') ----- + testCanRejectPromise + | p | + p := Promise new. + p rejectWith: Error new.! Item was added: + ----- Method: PromiseTest>>testCannotRejectFulfilledPromise (in category 'testing - monad') ----- + testCannotRejectFulfilledPromise + | p | + p := Promise unit: 1. + self should: [p rejectWith: Error new] raise: Error.! Item was added: + ----- Method: PromiseTest>>testCannotResolveaRejectedPromise (in category 'testing - monad') ----- + testCannotResolveaRejectedPromise + | p | + p := Promise new. + p rejectWith: Error new. + self should: [p resolveWith: 1] raise: Error.! Item was added: + ----- Method: PromiseTest>>testRejectWithInvokesErrorHandlers (in category 'testing - monad') ----- + testRejectWithInvokesErrorHandlers + | p error returnedError | + returnedError := nil. + error := KeyNotFound new. + p := Promise ifRejected: [:e | returnedError := e]. + p rejectWith: error. + 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'.! Item was changed: ----- Method: PromiseTest>>testSingleResolver (in category 'testing') ----- testSingleResolver | promise sum | sum := 0. promise := Promise new. promise whenResolved: [:val | sum := sum + val]. promise resolveWith: 5. + self assert: 5 equals: sum. - self should: [sum = 5]. ! Item was added: + ----- Method: PromiseTest>>testThenPermitsChainingOfPromises (in category 'testing - monad') ----- + testThenPermitsChainingOfPromises + | p q r | + p := Promise new. + q := p then: [:v | v * 2]. + r := q then: [:v | v + 1]. + p resolveWith: 4. + self assert: 4 * 2 equals: q value. + self assert: (4 * 2 + 1) equals: r value.! Item was added: + ----- Method: PromiseTest>>testThenReturnsaPromise (in category 'testing - monad') ----- + testThenReturnsaPromise + | p | + p := Promise new then: [:v | v * 2]. + self assert: Promise equals: p class.! Item was added: + ----- Method: PromiseTest>>testUnitReturnsaPromise (in category 'testing - monad') ----- + testUnitReturnsaPromise + | p | + p := Promise unit: 1. + self assert: Promise equals: p class. + self assert: p isResolved.! Item was added: + ----- Method: PromiseTest>>testifRejectedDoesNotRunBlockIfPromiseResolves (in category 'testing - monad') ----- + testifRejectedDoesNotRunBlockIfPromiseResolves + | p q error | + error := nil. + p := Promise new. + q := p ifRejected: [:e | error := e]. + p resolveWith: 1. + self deny: q isRejected. + self assert: nil equals: error.! Item was added: + ----- Method: PromiseTest>>testifRejectedRunsBlockIfPromiseFails (in category 'testing - monad') ----- + testifRejectedRunsBlockIfPromiseFails + | p q error | + error := nil. + p := Promise new. + q := p ifRejected: [:e | error := e]. + p rejectWith: KeyNotFound new. + self assert: q isRejected. + self assert: KeyNotFound equals: error class.!

1 0

The Trunk: KernelTests-fbs.252.mcz
by commits＠source.squeak.org 31 May '13

31 May '13

1 0

The Trunk: KernelTests-fbs.252.mcz
by commits＠source.squeak.org 31 May '13

31 May '13

1 0

The Trunk: Kernel-fbs.762.mcz
by commits＠source.squeak.org 31 May '13

31 May '13

Frank Shearar uploaded a new version of Kernel to project The Trunk: http://source.squeak.org/trunk/Kernel-fbs.762.mcz ==================== Summary ==================== Name: Kernel-fbs.762 Author: fbs Time: 30 May 2013, 11:07:50.674 pm UUID: 189ac08f-d45b-40f8-b7cd-e183ae46f3bf Ancestors: Kernel-fbs.761 Turn Promise into a fully chainable object with decent error handling. (This implements the Smalltalk equivalent of JavaScript's Promises/A+ specification.) =============== Diff against Kernel-fbs.761 =============== Item was changed: Object subclass: #Promise + instanceVariableNames: 'onError value resolvers mutex state error rejectors rejecters' - instanceVariableNames: 'isResolved value resolvers mutex' classVariableNames: '' poolDictionaries: '' category: 'Kernel-Processes'! + !Promise commentStamp: 'fbs 5/17/2013 18:23' prior: 0! - !Promise commentStamp: 'jcg 12/17/2009 02:22' 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, or from #pending -> #rejected. No other state changes may occur. Once #fulfilled or #rejected, a Promise's value must change.! - See class-comment of FutureNode.! Item was added: + ----- Method: Promise class>>ifRejected: (in category 'instance creation') ----- + ifRejected: aBlock + ^ Promise basicNew initializeWithIfRejected: aBlock.! Item was added: + ----- 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 basicNew initializeWithResolvedValue: anObject.! Item was added: + ----- Method: Promise>>error (in category 'accessing') ----- + error + ^ error.! Item was added: + ----- Method: Promise>>evaluateRejecter: (in category 'private') ----- + evaluateRejecter: rejecterBlock + ^ rejecterBlock cull: error.! Item was changed: ----- Method: Promise>>evaluateResolver: (in category 'private') ----- evaluateResolver: resolverBlock + ^ resolverBlock cull: value.! - resolverBlock cull: value.! Item was added: + ----- Method: Promise>>ifRejected: (in category 'monad') ----- + ifRejected: errBlock + ^ self then: [:ignored | "Do nothing"] ifRejected: errBlock.! Item was changed: ----- Method: Promise>>initialize (in category 'initialize') ----- initialize + state := #pending. - isResolved := false. resolvers := #(). + rejecters := #(). mutex := Mutex new.! Item was added: + ----- Method: Promise>>initializeWithIfRejected: (in category 'initialize') ----- + initializeWithIfRejected: aBlock + self initialize. + rejecters := {aBlock}.! Item was added: + ----- Method: Promise>>initializeWithResolvedValue: (in category 'initialize') ----- + initializeWithResolvedValue: anObject + self initialize. + self resolveWith: anObject.! Item was added: + ----- Method: Promise>>isPromise (in category 'testing') ----- + isPromise + ^ true.! Item was added: + ----- Method: Promise>>isRejected (in category 'testing') ----- + isRejected + ^ state == #rejected.! Item was changed: ----- Method: Promise>>isResolved (in category 'testing') ----- isResolved + ^ state == #fulfilled.! - ^isResolved! Item was added: + ----- Method: Promise>>printOn: (in category 'printing') ----- + printOn: aStream + aStream nextPutAll: 'a Promise'. + self isResolved ifTrue: [ + aStream + nextPutAll: '(resolved: '; + nextPutAll: value printString; + nextPutAll: ')']. + self isRejected ifTrue: [ + aStream + nextPutAll: '(rejected: '; + nextPutAll: error printString; + nextPutAll: ')'].! Item was added: + ----- Method: Promise>>rejectWith: (in category 'resolving') ----- + rejectWith: anObject + "Reject this promise." + mutex critical: [ + (state == #fulfilled) ifTrue: [self error: 'Promise was already resolved']. + (state == #rejected) ifTrue: [self error: 'Promise was already rejected']. + error := anObject. + state := #rejected. + rejecters do: [:r | self evaluateRejecter: r]].! Item was changed: ----- Method: Promise>>resolveWith: (in category 'resolving') ----- resolveWith: arg "Resolve this promise" mutex critical: [ + (state == #fulfilled) ifTrue: [self error: 'Promise was already resolved']. + (state == #rejected) ifTrue: [self error: 'Promise was already resolved']. - isResolved ifTrue: [self error: 'Promise was already resolved']. value := arg. + state := #fulfilled. + resolvers do: [:r | + self evaluateResolver: r]].! - isResolved := true. - resolvers do: [:r | self evaluateResolver: r]. - ].! Item was added: + ----- Method: Promise>>then: (in category 'monad') ----- + then: resolvedBlock + ^ self then: resolvedBlock ifRejected: [:ignored | "Do nothing"].! Item was added: + ----- Method: Promise>>then:ifRejected: (in category 'monad') ----- + 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 := Promise new. + self whenResolved: [:v | + [p resolveWith: (resolvedBlock value: v)] + on: Error do: [:e | p rejectWith: e]]. + self whenRejected: [:e | p rejectWith: (errBlock value: e)]. + ^ p.! Item was changed: ----- Method: Promise>>waitTimeoutMSecs: (in category 'waiting') ----- waitTimeoutMSecs: msecs "Wait for at most the given number of milliseconds for this promise to resolve. Answer true if it is resolved, false otherwise." | sema delay | sema := Semaphore new. self whenResolved: [sema signal]. delay := Delay timeoutSemaphore: sema afterMSecs: msecs. [sema wait] ensure: [delay unschedule]. + ^ self isResolved.! - ^isResolved! Item was added: + ----- Method: Promise>>whenRejected: (in category 'resolving') ----- + whenRejected: aBlock + "Evaluate aBlock when I am rejected" + aBlock numArgs <= 1 ifFalse: [self error: 'Must be 0- or 1-argument block']. + ^ mutex critical: [ + rejecters := rejecters copyWith: aBlock. + self isRejected ifTrue:[self evaluateRejecter: aBlock]. + ]! Item was changed: ----- Method: Promise>>whenResolved: (in category 'resolving') ----- whenResolved: aBlock "Evaluate aBlock when I am resolved" aBlock numArgs <= 1 ifFalse:[self error: 'Must be 0- or 1-argument block']. + ^ mutex critical: [ - mutex critical: [ resolvers := resolvers copyWith: aBlock. self isResolved ifTrue:[self evaluateResolver: aBlock]. ]!

1 0

The Trunk: Kernel-fbs.762.mcz
by commits＠source.squeak.org 31 May '13

31 May '13

1 0

The Trunk: Kernel-fbs.762.mcz
by commits＠source.squeak.org 31 May '13

31 May '13

1 0

The Trunk: Tools-fbs.467.mcz
by commits＠source.squeak.org 29 May '13

29 May '13

Frank Shearar uploaded a new version of Tools to project The Trunk: http://source.squeak.org/trunk/Tools-fbs.467.mcz ==================== Summary ==================== Name: Tools-fbs.467 Author: fbs Time: 29 May 2013, 10:22:41.649 am UUID: 89b5dde1-27f9-4b66-86ca-f134965c17a4 Ancestors: Tools-cmm.466 Apply "JIT development" to implementing a Trait application. =============== Diff against Tools-cmm.466 =============== Item was changed: ----- Method: Debugger>>buildNotifierWith:label:message: (in category 'toolbuilder') ----- buildNotifierWith: builder label: label message: messageString | windowSpec listSpec textSpec panelSpec quads | windowSpec := builder pluggableWindowSpec new. windowSpec model: self. windowSpec extent: 450 @ 156. "nice and wide to show plenty of the error msg" windowSpec label: label. windowSpec children: OrderedCollection new. panelSpec := builder pluggablePanelSpec new. panelSpec children: OrderedCollection new. quads := self preDebugButtonQuads. (self interruptedContext selector == #doesNotUnderstand:) ifTrue: [ quads := quads copyWith: { 'Create'. #createMethod. #magenta. 'create the missing method' } ]. + (#(#notYetImplemented #shouldBeImplemented #requirement) includes: self interruptedContext selector) ifTrue: [ - (#(#notYetImplemented #shouldBeImplemented) includes: self interruptedContext selector) ifTrue: [ quads := quads copyWith: { 'Create'. #createImplementingMethod. #magenta. 'implement the marked method' } ]. (self interruptedContext selector == #subclassResponsibility) ifTrue: [ quads := quads copyWith: { 'Create'. #createOverridingMethod. #magenta. 'create the missing overriding method' } ]. quads do:[:spec| | buttonSpec | buttonSpec := builder pluggableButtonSpec new. buttonSpec model: self. buttonSpec label: spec first. buttonSpec action: spec second. buttonSpec help: spec fourth. buttonSpec frame: self preDebugButtonQuadFrame. panelSpec children add: buttonSpec. ]. panelSpec layout: #horizontal. "buttons" panelSpec frame: self preDebugButtonQuadFrame. windowSpec children add: panelSpec. Preferences eToyFriendly | messageString notNil ifFalse:[ listSpec := builder pluggableListSpec new. listSpec model: self; list: #contextStackList; getIndex: #contextStackIndex; setIndex: #debugAt:; frame: self contextStackFrame. windowSpec children add: listSpec. ] ifTrue:[ message := messageString. textSpec := builder pluggableTextSpec new. textSpec model: self; getText: #preDebugMessageString; setText: nil; selection: nil; menu: #debugProceedMenu:; frame: self contextStackFrame. windowSpec children add: textSpec. ]. ^windowSpec!

1 0

The Trunk: Tools-fbs.467.mcz
by commits＠source.squeak.org 29 May '13

29 May '13

1 0

← Newer
1
2
3
4
5
6
7
8
...
36
Older →

Jump to page:

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

2005

Packages May 2013