feat!: publish packages under the @rsocket org

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

Author: viglucci

package.json

@@ -1,5 +1,5 @@
 {
-  "name": "rsocket-js",
+  "name": "@rsocket/js",
   "description": "A JavaScript implementation of the RSocket protocol (https://github.com/rsocket/rsocket).",
   "private": true,
   "license": "Apache-2.0",

packages/rsocket-adapter-rxjs/package.json

@@ -1,5 +1,5 @@
 {
-  "name": "rsocket-adapter-rxjs",
+  "name": "@rsocket/adapter-rxjs",
   "version": "1.0.0-alpha.4",
   "license": "Apache-2.0",
   "main": "dist/index",
@@ -19,8 +19,8 @@
     "test": "echo \"Error: no test specified\" && exit 0"
   },
   "dependencies": {
-    "rsocket-core": "^1.0.0-alpha.3",
-    "rsocket-messaging": "^1.0.0-alpha.3",
+    "@rsocket/core": "^1.0.0-alpha.3",
+    "@rsocket/messaging": "^1.0.0-alpha.3",
     "rxjs": "^7.4.0"
   },
   "devDependencies": {

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

@@ -21,8 +21,8 @@ import {
   OnNextSubscriber,
   OnTerminalSubscriber,
   Requestable,
-} from "rsocket-core";
-import { Codec } from "rsocket-messaging";
+} from "@rsocket/core";
+import { Codec } from "@rsocket/messaging";
 import {
   asyncScheduler,
   Observable,

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

@@ -20,8 +20,8 @@ import {
   OnNextSubscriber,
   OnTerminalSubscriber,
   Requestable,
-} from "rsocket-core";
-import { Codec } from "rsocket-messaging";
+} from "@rsocket/core";
+import { Codec } from "@rsocket/messaging";
 import { Observer, Subscription } from "rxjs";
 import { applyMixins } from "./Utils";
 

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

@@ -19,8 +19,8 @@ import {
   OnExtensionSubscriber,
   OnNextSubscriber,
   OnTerminalSubscriber,
-} from "rsocket-core";
-import { Codec } from "rsocket-messaging";
+} from "@rsocket/core";
+import { Codec } from "@rsocket/messaging";
 import { Observer, Subscription } from "rxjs";
 
 export default class ObserverToRSocketSubscriber<T>

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

@@ -21,8 +21,8 @@ import {
   OnTerminalSubscriber,
   Payload,
   Requestable,
-} from "rsocket-core";
-import { Codec } from "rsocket-messaging";
+} from "@rsocket/core";
+import { Codec } from "@rsocket/messaging";
 import { asyncScheduler, SchedulerLike, Subscriber, TeardownLogic } from "rxjs";
 import ObserverToBufferingRSocketSubscriber from "./ObserverToBufferingRSocketSubscriber";
 import RSocketPublisherToPrefetchingObservable from "./RSocketPublisherToPrefetchingObservable";

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

@@ -20,8 +20,8 @@ import {
   OnNextSubscriber,
   OnTerminalSubscriber,
   Payload,
-} from "rsocket-core";
-import { Codec } from "rsocket-messaging";
+} from "@rsocket/core";
+import { Codec } from "@rsocket/messaging";
 import { Observable, Subscriber, TeardownLogic, Unsubscribable } from "rxjs";
 
 export default class RSocketPublisherToObservable<T>

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

@@ -21,8 +21,8 @@ import {
   OnTerminalSubscriber,
   Payload,
   Requestable,
-} from "rsocket-core";
-import { Codec } from "rsocket-messaging";
+} from "@rsocket/core";
+import { Codec } from "@rsocket/messaging";
 import {
   asyncScheduler,
   Observable,

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

@@ -19,16 +19,16 @@
 import {
   encodeCompositeMetadata,
   WellKnownMimeType,
-} from "rsocket-composite-metadata";
+} from "@rsocket/composite-metadata";
 import {
   Cancellable,
   OnExtensionSubscriber,
   OnNextSubscriber,
   OnTerminalSubscriber,
   Requestable,
   RSocket,
-} from "rsocket-core";
-import { Codec } from "rsocket-messaging";
+} from "@rsocket/core";
+import { Codec } from "@rsocket/messaging";
 import {
   asyncScheduler,
   concatMap,

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

@@ -24,8 +24,8 @@ import {
   OnTerminalSubscriber,
   Payload,
   Requestable,
-} from "rsocket-core";
-import { Codec } from "rsocket-messaging";
+} from "@rsocket/core";
+import { Codec } from "@rsocket/messaging";
 import { asyncScheduler, Observable, SchedulerLike } from "rxjs";
 import ObserverToBufferingRSocketSubscriber from "./ObserverToBufferingRSocketSubscriber";
 import ObserverToRSocketSubscriber from "./ObserverToRSocketSubscriber";