fixes es6 constraints for calling constructor with new keyword

Signed-off-by: OlegDokuka <[email protected]>

Author: OlegDokuka

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

@@ -92,7 +92,7 @@ class Observer2BufferingSubscriberToPublisher2PrefetchingObservable<In, Out>
     scheduler: SchedulerLike = asyncScheduler
   ) {
     super(exchangeFunction, prefetch, outputCodec, scheduler);
-    ObserverToBufferingRSocketSubscriber.call(this, 0, undefined, inputCodec);
+    this.init(0, undefined, inputCodec);
   }
 
   _subscribe(s: Subscriber<Out>): TeardownLogic {

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

@@ -36,18 +36,33 @@ class ObserverToBufferingRSocketSubscriber<T>
   extends Subscription
   implements Observer<T>, Cancellable, Requestable, OnExtensionSubscriber
 {
-  protected wip: number = 0;
+  protected requested: number;
+  protected subscriber: OnTerminalSubscriber &
+    OnNextSubscriber &
+    OnExtensionSubscriber;
+  protected inputCodec: Codec<T>;
+  protected wip: number;
   private e: Error;
   private done: boolean;
 
   constructor(
-    protected requested: number,
-    protected readonly subscriber: OnTerminalSubscriber &
-      OnNextSubscriber &
-      OnExtensionSubscriber,
-    protected readonly inputCodec: Codec<T>
+    requested: number,
+    subscriber: OnTerminalSubscriber & OnNextSubscriber & OnExtensionSubscriber,
+    inputCodec: Codec<T>
   ) {
     super();
+    this.init(requested, subscriber, inputCodec);
+  }
+
+  protected init(
+    requested: number,
+    subscriber: OnTerminalSubscriber & OnNextSubscriber & OnExtensionSubscriber,
+    inputCodec: Codec<T>
+  ) {
+    this.requested = requested;
+    this.subscriber = subscriber;
+    this.inputCodec = inputCodec;
+    this.wip = 0;
   }
 
   request(n: number) {

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

@@ -74,12 +74,7 @@ class RSocketPublisher2PrefetchingObservableToObserver2BufferingRSocketSubscribe
     scheduler: SchedulerLike = asyncScheduler
   ) {
     super(() => subscriber, prefetch, outputCodec, scheduler);
-    ObserverToBufferingRSocketSubscriber.call(
-      this,
-      requested,
-      subscriber,
-      inputCodec
-    );
+    this.init(requested, subscriber, inputCodec);
   }
 
   protected _subscribe(observer: Subscriber<any>): TeardownLogic {