equal
deleted
inserted
replaced
4 |
4 |
5 WriteStream subclass:#TransformWriteStream |
5 WriteStream subclass:#TransformWriteStream |
6 instanceVariableNames:'buffer block closeBlock process incompleteCount readReady |
6 instanceVariableNames:'buffer block closeBlock process incompleteCount readReady |
7 writeReady closeReady' |
7 writeReady closeReady' |
8 classVariableNames:'' |
8 classVariableNames:'' |
9 poolDictionaries:'XtreamsPool' |
9 poolDictionaries:'Xtreams::XtreamsPool' |
10 category:'Xtreams-Transforms' |
10 category:'Xtreams-Transforms' |
11 ! |
11 ! |
12 |
12 |
13 TransformWriteStream comment:'Transform write stream provides the most expressive form of transformation. The transformation is described by a binary block that is given two arguments, @input and @output. The @input is a virtual stream of elements written into the stream. The @output is the destination stream under the transform stream. 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 consume everything written into the stream, or until an Incomplete is raised by the destination. |
13 TransformWriteStream comment:'Transform write stream provides the most expressive form of transformation. The transformation is described by a binary block that is given two arguments, @input and @output. The @input is a virtual stream of elements written into the stream. The @output is the destination stream under the transform stream. 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 consume everything written into the stream, or until an Incomplete is raised by the destination. |
14 |
14 |