fix(parseobservablemarble): fix subscription offset

Author: kwonoj

src/marbles/parseObservableMarble.ts

@@ -23,10 +23,11 @@ const parseObservableMarble = <T>(
     throw new Error(`Observable marble cannot have unsubscription marker ${SubscriptionMarbleToken.UNSUBSCRIBE}`);
   }
 
-  const subscriptionIndex = marble.indexOf(SubscriptionMarbleToken.SUBSCRIBE) * frameTimeFactor;
-  const frameOffset = subscriptionIndex < 0 ? 0 : subscriptionIndex;
+  const marbleTokenArray = Array.from(marble).filter(token => token !== ObservableMarbleToken.NOOP);
+
+  const subscriptionIndex = marbleTokenArray.join('').indexOf(SubscriptionMarbleToken.SUBSCRIBE) * frameTimeFactor;
+  const frameOffset = subscriptionIndex < 0 ? 0 : -subscriptionIndex;
 
-  const marbleTokenArray = Array.from(marble).filter(token => token !== ObservableMarbleToken.NOOP).slice(frameOffset);
   const values = marbleTokenArray.reduce(
     observableTokenParseReducer(value || null, error, materializeInnerObservables, frameTimeFactor),
     {

src/marbles/tokenParseReducer.ts

@@ -143,6 +143,7 @@ const observableTokenParseReducer = <T>(
       acc.simultaneousGrouped = false;
       break;
     case SubscriptionMarbleToken.SUBSCRIBE:
+      acc = increaseTimeFrame(acc, frameTimeFactor);
       break;
     default:
       if (acc.expandingTokenCount > 0) {