--- a/transforms/extensions.st	Fri Mar 15 22:48:33 2013 +0000
+++ b/transforms/extensions.st	Fri Mar 15 19:17:42 2013 -0400
@@ -1,6 +1,4 @@
-"{ Package: 'stx:goodies/xtreams/transforms' }"
-
-!
+"{ Package: 'stx:goodies/xtreams/transforms' }"!
 
 !Xtreams::ReadStream methodsFor:'transforming'!
 
@@ -15,6 +13,7 @@
 	"
 	^CollectReadStream on: self block: aBlock
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 depairing
@@ -26,6 +25,7 @@
 		out put: association key.
 		out put: association value]
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 doing: aBlock
@@ -37,6 +37,7 @@
 	"
 	^self collecting: [:each | (aBlock value: each). each]
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 duplicating: aWriteStream
@@ -50,6 +51,7 @@
 	"
 	^DuplicateReadStream on: self duplicate: aWriteStream
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 encoding: anEncoding
@@ -68,6 +70,7 @@
 	"
 	^EncodeReadStream on: self encoding: anEncoding
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 encodingBase64
@@ -95,6 +98,7 @@
 			buffer: (RingBuffer on: (ByteArray new: 3));
 			yourself
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 encodingHex
@@ -112,6 +116,7 @@
 		contentsSpecies: ByteString;
 		yourself
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 injecting: initialObject into: aBlock
@@ -126,6 +131,7 @@
 	nextObject := initialObject.
 	^self collecting: [:each | nextObject := aBlock cull: nextObject cull: each]
 ! !
+
 !Xtreams::ReadStream methodsFor:'interpreting'!
 
 interpreting: type
@@ -143,6 +149,7 @@
 	"
 	^self interpreting: type cacheSize: 1
 ! !
+
 !Xtreams::ReadStream methodsFor:'interpreting'!
 
 interpreting: type cacheSize: size
@@ -161,6 +168,7 @@
 	"
 	^InterpretedReadStream on: self type: type cacheSize: size
 ! !
+
 !Xtreams::ReadStream methodsFor:'interpreting'!
 
 interpreting: reader size: byteSize
@@ -179,6 +187,7 @@
 	"
 	^InterpretedReadStream on: self bytesPerElement: byteSize contentsSpecies: Array operation: reader cacheSize: 1
 ! !
+
 !Xtreams::ReadStream methodsFor:'interpreting'!
 
 interpreting: reader size: byteSize cacheSize: cacheSize
@@ -198,6 +207,7 @@
 	"
 	^InterpretedReadStream on: self bytesPerElement: byteSize contentsSpecies: Array operation: reader cacheSize: cacheSize
 ! !
+
 !Xtreams::ReadStream methodsFor:'interpreting'!
 
 marshaling
@@ -211,6 +221,7 @@
 	"
 	^ObjectReadStream on: self
 ! !
+
 !Xtreams::ReadStream methodsFor:'interpreting'!
 
 marshaling: aMarshaler
@@ -226,6 +237,7 @@
 	"
 	^ObjectReadStream on: self marshaler: aMarshaler
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 monitoring: aNotificationBlock every: aNotificationInterval
@@ -276,6 +288,7 @@
 	timer := Timer every: aNotificationInterval resume: notifyProcess.
 	^monitoring
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 pairing
@@ -283,6 +296,7 @@
 
 	^self transforming: [:in :out | out put: (Association key: in get value: in get)]
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 positioning
@@ -295,6 +309,7 @@
 		ifTrue: [self]
 		ifFalse:        [PositionReadStream on: self]
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 rejecting: aBlock
@@ -310,6 +325,7 @@
 		aBlock cull: value] whileTrue.
 		output put: value]
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 selecting: aBlock
@@ -325,6 +341,7 @@
 		aBlock cull: value] whileFalse.
 		output put: value]
 ! !
+
 !Xtreams::ReadStream methodsFor:'transforming'!
 
 transforming: aBlock
@@ -349,6 +366,7 @@
 	"
 	^TransformReadStream on: self block: aBlock
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 buffering: bufferSize
@@ -362,6 +380,7 @@
 	"
 	^BufferedWriteStream on: self bufferSize: bufferSize
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 collecting: aBlock
@@ -375,6 +394,7 @@
 	"
 	^CollectWriteStream on: self block: aBlock
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 depairing
@@ -386,6 +406,7 @@
 		out put: association key.
 		out put: association value]
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 doing: aBlock
@@ -397,6 +418,7 @@
 	"
 	^self collecting: [:each | (aBlock value: each). each]
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 duplicating: aWriteStream
@@ -412,6 +434,7 @@
 	"
 	^DuplicateWriteStream on: self duplicate: aWriteStream
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 encoding: anEncoding
@@ -429,6 +452,7 @@
 	"
 	^EncodeWriteStream on: self encoding: anEncoding
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 encodingBase64
@@ -453,6 +477,7 @@
 		buffer: (RingBuffer on: (ByteArray new: 3));
 		yourself
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 encodingHex
@@ -468,6 +493,7 @@
 		contentsSpecies: ByteString;
 		yourself
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 injecting: initialObject into: aBlock
@@ -482,6 +508,7 @@
 	nextObject := initialObject.
 	^self collecting: [:each | nextObject := aBlock cull: nextObject cull: each]
 ! !
+
 !Xtreams::WriteStream methodsFor:'interpreting'!
 
 interpreting: type
@@ -499,6 +526,7 @@
 	"
 	^self interpreting: type cacheSize: 1
 ! !
+
 !Xtreams::WriteStream methodsFor:'interpreting'!
 
 interpreting: type cacheSize: size
@@ -517,6 +545,7 @@
 	"
 	^InterpretedWriteStream on: self type: type cacheSize: size
 ! !
+
 !Xtreams::WriteStream methodsFor:'interpreting'!
 
 interpreting: writer size: byteSize
@@ -535,6 +564,7 @@
 	"
 	^InterpretedWriteStream on: self bytesPerElement: byteSize contentsSpecies: Array operation: writer cacheSize: 1
 ! !
+
 !Xtreams::WriteStream methodsFor:'interpreting'!
 
 interpreting: writer size: byteSize cacheSize: cacheSize
@@ -554,6 +584,7 @@
 	"
 	^InterpretedWriteStream on: self bytesPerElement: byteSize contentsSpecies: Array operation: writer cacheSize: cacheSize
 ! !
+
 !Xtreams::WriteStream methodsFor:'interpreting'!
 
 marshaling
@@ -568,6 +599,7 @@
 	"
 	^ObjectWriteStream on: self
 ! !
+
 !Xtreams::WriteStream methodsFor:'interpreting'!
 
 marshaling: aMarshaler
@@ -583,6 +615,7 @@
 	"
 	^ObjectWriteStream on: self marshaler: aMarshaler
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 monitoring: aNotificationBlock every: aNotificationInterval
@@ -619,6 +652,7 @@
 	timer := Timer every: aNotificationInterval resume: notifyProcess.
 	^monitoring
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 pairing
@@ -626,6 +660,7 @@
 
 	^self transforming: [:in :out | out put: (Association key: in get value: in get)]
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 positioning
@@ -638,6 +673,7 @@
 		ifTrue: [self]
 		ifFalse:        [PositionWriteStream on: self]
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 rejecting: aBlock
@@ -649,6 +685,7 @@
 	"
 	^self selecting: [:each | (aBlock cull: each) not]
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 selecting: aBlock
@@ -664,6 +701,7 @@
 		aBlock cull: value] whileFalse.
 		output put: value]
 ! !
+
 !Xtreams::WriteStream methodsFor:'transforming'!
 
 transforming: aBlock
@@ -691,3 +729,10 @@
 	"
 	^TransformWriteStream on: self block: aBlock
 ! !
+
+!stx_goodies_xtreams_transforms class methodsFor:'documentation'!
+
+extensionsVersion_HG
+
+    ^ '$Changeset: <not expanded> $'
+! !
\ No newline at end of file