fixes format

Author: OlegDokuka

package.json

@@ -18,7 +18,7 @@
   "scripts": {
     "build": "cross-env NODE_ENV=production node ./scripts/build.js",
     "jest": "cross-env NODE_ENV=test jest",
-    "lint": "yarn run lint-prettier && eslint . --cache",
+    "lint": "yarn run lint-prettier && eslint . --cache --fix",
     "lint-prettier": "node ./scripts/prettier.js lint",
     "prettier": "node ./scripts/prettier.js write && eslint . --cache --fix",
     "tck": "yarn run build && node ./packages/rsocket-tck/build/index.js \"$@\"",

packages/rsocket-core/src/Invariant.js

@@ -17,13 +17,19 @@
  * The invariant message will be stripped in production, but the invariant will
  * remain to ensure logic does not differ in production.
  */
-function invariant(condition: mixed, format: string, ...args: Array<mixed>): void {
+function invariant(
+  condition: mixed,
+  format: string,
+  ...args: Array<mixed>
+): void {
   if (!condition) {
     let error;
 
     if (format === undefined) {
-      error = new Error('Minified exception occurred; use the non-minified ' +
-        'dev environment for the full error message and additional helpful warnings.');
+      error = new Error(
+        'Minified exception occurred; use the non-minified ' +
+          'dev environment for the full error message and additional helpful warnings.',
+      );
     } else {
       let argIndex = 0;
       error = new Error(format.replace(/%s/g, () => String(args[argIndex++])));

packages/rsocket-core/src/RSocketMachine.js

@@ -482,8 +482,10 @@ class RSocketMachineImpl<D, M> implements RSocketMachine<D, M> {
                   },
                 });
               } else {
-                console.warn('RSocketClient: re-entrant call to request n before initial' +
-                  ' channel established.');
+                console.warn(
+                  'RSocketClient: re-entrant call to request n before initial' +
+                    ' channel established.',
+                );
               }
             }
           },

packages/rsocket-flowable/src/Flowable.js

@@ -28,7 +28,6 @@ import FlowableMapOperator from './FlowableMapOperator';
 import FlowableTakeOperator from './FlowableTakeOperator';
 import invariant from './Invariant';
 
-
 export type Source<T> = (subscriber: ISubscriber<T>) => void;
 
 /**

packages/rsocket-flowable/src/Invariant.js

@@ -17,13 +17,19 @@
  * The invariant message will be stripped in production, but the invariant will
  * remain to ensure logic does not differ in production.
  */
-function invariant(condition: mixed, format: string, ...args: Array<mixed>): void {
+function invariant(
+  condition: mixed,
+  format: string,
+  ...args: Array<mixed>
+): void {
   if (!condition) {
     let error;
 
     if (format === undefined) {
-      error = new Error('Minified exception occurred; use the non-minified ' +
-        'dev environment for the full error message and additional helpful warnings.');
+      error = new Error(
+        'Minified exception occurred; use the non-minified ' +
+          'dev environment for the full error message and additional helpful warnings.',
+      );
     } else {
       let argIndex = 0;
       error = new Error(format.replace(/%s/g, () => String(args[argIndex++])));

packages/rsocket-tck/src/Deferred.js

@@ -52,11 +52,17 @@ export class Deferred<Tvalue, Treason> {
     return Promise.prototype.catch.apply(this._promise, arguments);
   }
 
-  then(onFulfill?: ?(value: any) => mixed, onReject?: ?(error: any) => mixed): Promise<any> {
+  then(
+    onFulfill?: ?(value: any) => mixed,
+    onReject?: ?(error: any) => mixed,
+  ): Promise<any> {
     return Promise.prototype.then.apply(this._promise, arguments);
   }
 
-  done(onFulfill?: ?(value: any) => mixed, onReject?: ?(error: any) => mixed): void {
+  done(
+    onFulfill?: ?(value: any) => mixed,
+    onReject?: ?(error: any) => mixed,
+  ): void {
     // Embed the polyfill for the non-standard Promise.prototype.done so that
     // users of the open source fbjs don't need a custom lib for Promise
     const promise = arguments.length

packages/rsocket-tck/src/RSocketTckClient.js

@@ -100,7 +100,9 @@ async function run(options: Options): Promise<void> {
   }
   process.stdout.write(chalk.inverse('Running TCK tests') + '\n');
   process.stdout.write(`Using testfile${testfilePath}\n`);
-  process.stdout.write(`Connecting to server at ${options.host}:${options.port}\n`);
+  process.stdout.write(
+    `Connecting to server at ${options.host}:${options.port}\n`,
+  );
   const testSource = fs.readFileSync(testfilePath, 'utf8');
   const testCases = testSource
     .split('!')

packages/rsocket-tcp-client/src/RSocketTcpClient.js

@@ -210,7 +210,9 @@ export class RSocketTcpClient extends RSocketTcpConnection {
 
   connect(): void {
     if (this.getConnectionState().kind !== 'NOT_CONNECTED') {
-      throw new Error('RSocketTcpClient: Cannot connect(), a connection is already established.');
+      throw new Error(
+        'RSocketTcpClient: Cannot connect(), a connection is already established.',
+      );
     }
     this.setConnectionStatus(CONNECTION_STATUS.CONNECTING);
     const socket = net.connect(this._options);
@@ -237,7 +239,9 @@ export class RSocketTlsClient extends RSocketTcpConnection {
 
   connect(): void {
     if (this.getConnectionState().kind !== 'NOT_CONNECTED') {
-      throw new Error('RSocketTcpClient: Cannot connect(), a connection is already established.');
+      throw new Error(
+        'RSocketTcpClient: Cannot connect(), a connection is already established.',
+      );
     }
     this.setConnectionStatus(CONNECTION_STATUS.CONNECTING);
     const socket = tls.connect(this._options);

packages/rsocket-websocket-client/src/RSocketWebSocketClient.js

@@ -67,8 +67,10 @@ export default class RSocketWebSocketClient implements DuplexConnection {
 
   connect(): void {
     if (this._status.kind !== 'NOT_CONNECTED') {
-      throw new Error('RSocketWebSocketClient: Cannot connect(), a connection is already ' +
-        'established.');
+      throw new Error(
+        'RSocketWebSocketClient: Cannot connect(), a connection is already ' +
+          'established.',
+      );
     }
     this._setConnectionStatus(CONNECTION_STATUS.CONNECTING);
 
@@ -217,7 +219,9 @@ export default class RSocketWebSocketClient implements DuplexConnection {
         ? serializeFrameWithLength(frame, this._encoders)
         : serializeFrame(frame, this._encoders);
       if (!this._socket) {
-        throw new Error('RSocketWebSocketClient: Cannot send frame, not connected.');
+        throw new Error(
+          'RSocketWebSocketClient: Cannot send frame, not connected.',
+        );
       }
       this._socket.send(buffer);
     } catch (error) {

packages/rsocket-websocket-server/src/RSocketWebSocketServer.js

@@ -140,8 +140,10 @@ class WSDuplexConnection implements DuplexConnection {
     let isSubscribed = false;
     this._receiver = new Flowable(subscriber => {
       if (isSubscribed) {
-        throw new Error('RSocketWebSocketServer: Multicast receive() is not supported. Be sure ' +
-          'to receive/subscribe only once.');
+        throw new Error(
+          'RSocketWebSocketServer: Multicast receive() is not supported. Be sure ' +
+            'to receive/subscribe only once.',
+        );
       }
       isSubscribed = true;