Skip to content

Commit e60d6f1

Browse files
committed
fix(tokenparsereducer): support simultaneous sub-unsub
1 parent cfe8b5b commit e60d6f1

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/marbles/tokenParseReducer.ts

+3-1
Original file line numberDiff line numberDiff line change
@@ -184,7 +184,9 @@ const subscriptionTokenParseReducer = (frameTimeFactor: number, maxFrame: number
184184
switch (token) {
185185
case SubscriptionMarbleToken.SUBSCRIBE:
186186
acc.subscriptionFrame = acc.currentTimeFrame;
187-
acc = increaseTimeFrame(acc, frameTimeFactor);
187+
if (!acc.simultaneousGrouped) {
188+
acc = increaseTimeFrame(acc, frameTimeFactor);
189+
}
188190
break;
189191
case SubscriptionMarbleToken.UNSUBSCRIBE:
190192
acc.unsubscriptionFrame = acc.currentTimeFrame;

0 commit comments

Comments
 (0)