equal
deleted
inserted
replaced
3 "{ NameSpace: Xtreams }" |
3 "{ NameSpace: Xtreams }" |
4 |
4 |
5 ReadStream subclass:#TransformReadStream |
5 ReadStream subclass:#TransformReadStream |
6 instanceVariableNames:'buffer bufferWriting sourceAtEnd block closeBlock' |
6 instanceVariableNames:'buffer bufferWriting sourceAtEnd block closeBlock' |
7 classVariableNames:'' |
7 classVariableNames:'' |
8 poolDictionaries:'XtreamsPool' |
8 poolDictionaries:'Xtreams::XtreamsPool' |
9 category:'Xtreams-Transforms' |
9 category:'Xtreams-Transforms' |
10 ! |
10 ! |
11 |
11 |
12 TransformReadStream comment:'Transform read stream provides the most expressive form of transformation. The transformation is described by a binary block that is given two arguments, @input and @output. Both @input and @output are streams themselves. The block can read arbitrary amount of elements from @input (including none) and write arbitrary amount of elements into @output (including none).The block will be invoked as many times as necessary to produce the required number of elements, or until an Incomplete is raised. Consequently if the block handles Incomplete from the input, it has to raise another Incomplete at some point, otherwise the stream will never end. |
12 TransformReadStream comment:'Transform read stream provides the most expressive form of transformation. The transformation is described by a binary block that is given two arguments, @input and @output. Both @input and @output are streams themselves. The block can read arbitrary amount of elements from @input (including none) and write arbitrary amount of elements into @output (including none).The block will be invoked as many times as necessary to produce the required number of elements, or until an Incomplete is raised. Consequently if the block handles Incomplete from the input, it has to raise another Incomplete at some point, otherwise the stream will never end. |
13 |
13 |