From 7e1dede7ff362893f1d6334f5a7fbca23ccd0681 Mon Sep 17 00:00:00 2001
From: Pavel Potapov <scavengerr@gmail.com>
Date: Wed, 5 Jan 2022 14:27:14 +0300
Subject: [PATCH] Fix error messages in `onError` and in `onNext`.

---
 packages/rsocket-flowable/src/Flowable.js | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/packages/rsocket-flowable/src/Flowable.js b/packages/rsocket-flowable/src/Flowable.js
index 7c061b92..5dc2f98c 100644
--- a/packages/rsocket-flowable/src/Flowable.js
+++ b/packages/rsocket-flowable/src/Flowable.js
@@ -173,7 +173,7 @@ class FlowableSubscriber<T> implements ISubscriber<T> {
     if (this._started && !this._active) {
       console.warn(
         'Flowable: Invalid call to onError(): %s.',
-        this._active
+        this._started
           ? 'onComplete/onError was already called'
           : 'onSubscribe has not been called',
       );
@@ -188,7 +188,7 @@ class FlowableSubscriber<T> implements ISubscriber<T> {
     if (!this._active) {
       console.warn(
         'Flowable: Invalid call to onNext(): %s.',
-        this._active
+        this._started
           ? 'onComplete/onError was already called'
           : 'onSubscribe has not been called',
       );