Skip to content

Commit

Permalink
Added RsStream>>#iterator and #reverseIteraror for supporting easiler…
Browse files Browse the repository at this point in the history 
… iteration
  • Loading branch information
@mumez
mumez committed Oct 2, 2024
1 parent 47c114a commit ddcc11f
Show file tree
Hide file tree
Showing 19 changed files with 52 additions and 11 deletions.
3 changes: 3 additions & 0 deletions repository/RediStick-Stream-Objects.package/RsStream.class/instance/iterator.st
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
iterating
iterator
^ self iteratorClass on: self
3 changes: 3 additions & 0 deletions repository/RediStick-Stream-Objects.package/RsStream.class/instance/reverseIterator.st
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
iterating
reverseIterator
^ self iterator reversed
5 changes: 5 additions & 0 deletions repository/RediStick-Stream-Objects.package/RsStreamIterator.class/class/on.from..st
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,5 @@
instance creation
on: aRsStream from: fromId
^ (self on: aRsStream)
initFromId: fromId;
yourself
5 changes: 4 additions & 1 deletion repository/RediStick-Stream-Objects.package/RsStreamIterator.class/class/on.nextFrom..st
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,6 @@
instance creation
on: aRsStream nextFrom: fromId
^ (self on: aRsStream) initFromId: fromId
^ (self on: aRsStream)
initFromId: fromId;
initCurrentId: fromId;
yourself
3 changes: 3 additions & 0 deletions ...sitory/RediStick-Stream-Objects.package/RsStreamIterator.class/instance/basicCurrentId.st
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
accessing
basicCurrentId
^ currentId
2 changes: 1 addition & 1 deletion ...ory/RediStick-Stream-Objects.package/RsStreamIterator.class/instance/by.do.whileFalse..st
View file
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
actions
by: step do: aBlock whileFalse: endConditionBlock
| entries |
entries := self contentsNextFrom: self currentId count: step.
entries := self entriesFrom: self currentId count: step.
entries do: [ :each |
aBlock value: each.
self currentId: each id ].
Expand Down
3 changes: 3 additions & 0 deletions ...y/RediStick-Stream-Objects.package/RsStreamIterator.class/instance/contentsFrom.count..st
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
private
contentsFrom: entryId count: step
^ self stream contentsFrom: entryId count: step
4 changes: 2 additions & 2 deletions repository/RediStick-Stream-Objects.package/RsStreamIterator.class/instance/currentId.st
View file
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
accessing
currentId

^ currentId
currentId ifNil: [ ^ self fallbackId ].
^ currentId
4 changes: 4 additions & 0 deletions ...ry/RediStick-Stream-Objects.package/RsStreamIterator.class/instance/entriesFrom.count..st
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
private
entriesFrom: entryId count: step
self isInclusive ifTrue: [ ^ self contentsFrom: entryId count: step ].
^ self contentsNextFrom: entryId count: step
3 changes: 3 additions & 0 deletions repository/RediStick-Stream-Objects.package/RsStreamIterator.class/instance/fallbackId.st
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
private
fallbackId
^ self stream first id
3 changes: 3 additions & 0 deletions ...sitory/RediStick-Stream-Objects.package/RsStreamIterator.class/instance/initCurrentId..st
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
initialization
initCurrentId: fromIdLikeThing
currentId := fromIdLikeThing ifNotNil: [ fromIdLikeThing asStreamMessageId ].
5 changes: 1 addition & 4 deletions repository/RediStick-Stream-Objects.package/RsStreamIterator.class/instance/initFromId..st
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,3 @@
initialization
initFromId: fromIdLikeThing
fromId := fromIdLikeThing
ifNil: [ RsStreamMessageId zero ]
ifNotNil: [ fromIdLikeThing asStreamMessageId ].
currentId := fromId
fromId := fromIdLikeThing ifNotNil: [ fromIdLikeThing asStreamMessageId ].
3 changes: 3 additions & 0 deletions repository/RediStick-Stream-Objects.package/RsStreamIterator.class/instance/isInclusive..st
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
accessing
isInclusive: aBoolean
isInclusive := aBoolean
4 changes: 4 additions & 0 deletions repository/RediStick-Stream-Objects.package/RsStreamIterator.class/instance/isInclusive.st
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
testing
isInclusive
isInclusive ifNil: [ ^ currentId isNil ].
^ isInclusive
2 changes: 1 addition & 1 deletion repository/RediStick-Stream-Objects.package/RsStreamIterator.class/instance/reversed.st
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
converting
reversed
^ RsStreamReverseIterator on: self stream nextFrom: self currentId
^ RsStreamReverseIterator on: self stream nextFrom: self basicCurrentId
3 changes: 2 additions & 1 deletion repository/RediStick-Stream-Objects.package/RsStreamIterator.class/properties.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,8 @@
"name",
"stream",
"fromId",
"currentId"
"currentId",
"isInclusive"
],
"name" : "RsStreamIterator",
"type" : "normal"
Expand Down
3 changes: 3 additions & 0 deletions ...tick-Stream-Objects.package/RsStreamReverseIterator.class/instance/contentsFrom.count..st
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
private
contentsFrom: entryId count: step
^ self stream contentsReversedFrom: entryId count: step
3 changes: 3 additions & 0 deletions ...ory/RediStick-Stream-Objects.package/RsStreamReverseIterator.class/instance/fallbackId.st
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
private
fallbackId
^ self stream last id
2 changes: 1 addition & 1 deletion ...itory/RediStick-Stream-Objects.package/RsStreamReverseIterator.class/instance/reversed.st
View file
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
converting
reversed
^ RsStreamIterator on: self stream nextFrom: self currentId
^ RsStreamIterator on: self stream nextFrom: self basicCurrentId

0 comments on commit ddcc11f

Please sign in to comment.