fixes request channel to drop second element (#244)

unexpectedly, in the rxjs `partition` operator the index is a local variable per subscription, thus the second subscription starts indexing from 0 once again even though the element is a second one (index should be 1 in that case). Therefore, to overcome this problem the PR introduces a local variable to track the first element.

Signed-off-by: Kevin Viglucci <[email protected]>

Author: OlegDokuka

packages/rsocket-adapter-rxjs/src/Requesters.ts

@@ -136,14 +136,22 @@ export function requestChannel<TData, RData>(
   rsocket: RSocket,
   metadata?: Map<string | number | WellKnownMimeType, Buffer>
 ) => Observable<RData> {
+  let once = false;
   const [firstValueObservable, restValuesObservable] = partition(
     datas.pipe(
       share({
         connector: () => new Subject(),
         resetOnRefCountZero: true,
       })
     ),
-    (_value, index) => index === 0
+    (_value) => {
+      const previous = once;
+      if (!previous) {
+        once = true;
+      }
+
+      return !previous;
+    }
   );
 
   return (