On Sat, Jan 1, 2011 at 6:03 PM,
<mkobetic@gmail.com> wrote:
I updated the Xtreams port (http://www.squeaksource.com/Xtreams) over the holidays to catch up with the state on VW side. The primary changes are updates/fixes of the positioning API and a cleanup/extension of the slicing API. The slicers are replaced by much simpler #slicing setup and the inverse, #stitching, was added (the updated documentation can be found in the usual place: http://code.google.com/p/xtreams/wiki/Substreams). More details on the changes below.
Enjoy,
Martin
Positioning updates:
* ++/--/+=/-=/position: now return the argument instead of self
* they all also skip as far as they can raising Incomplete with the count of the actual amount skipped
* this means that the positioning wrapper will advance as far forward as it needs to satisfy the request, in case of -= it means it will advance all the way to the end of the underlying stream.
* similarly asking a positioning wrapper for length or available will make it advance to the end
* in the other direction, positioning wrapper can't skip past the beginning of its buffer, so if the buffer window moves forward, so does the absolute position; position 0 is always the beginning of the buffer, whereever it is at any given moment
* also extended ++ and -- to call the other if the argument is negative (it helps with implementation of the others)
All read/write/positioning calls except put:/get/read: now consistently return element counts so that one can use a computation as an argument and then obtain the actual number in response. This simplifies common patterns like:
� � � �actual := [ stream ++ (x max: y) ] on: Incomplete do: [ :ex | ex count ].
�instead of:
� � � �actual := x max: y.
� � � �[ stream ++ actual ] on: Incomplete do: [ :ex | actual := ex count ].
Slicing/Stitching updates:
Replacing all the -er: slicer creation methods with the new #slicing and adding complementary #stitching.
* #slicing is sent to a substream "prototype" and clones it when next slice is needed, e.g.
� � � �(stream limiting: 3) slicing
* #stitching is sent to a read stream of streams and makes it look like one continuous stream
� � � �[ stream limiting: stream get ] reading stitching
* stitching replaces the experimental proto and concatentation streams
* ReadStream>>, is now implemented with stitching too