fix: imports in requestChannel impl and async examples

rsocket · Jan 12, 2022 · 04fca05 · 04fca05
1 parent f30d5b6
commit 04fca05
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 4 deletions.
diff --git a/packages/rsocket-adapter-async/src/lib/responders/requestChannel.ts b/packages/rsocket-adapter-async/src/lib/responders/requestChannel.ts
@@ -9,7 +9,7 @@ import {
   Payload,
   Requestable,
 } from "@rsocket/core";
-import { RxRespondersFactory } from "@rsocket/rxjs";
+import { RxRespondersFactory } from "@rsocket/adapter-rxjs";
 import { eachValueFrom } from "rxjs-for-await";
 
 export default function requestChannel<IN, OUT>(

diff --git a/packages/rsocket-examples/package.json b/packages/rsocket-examples/package.json
@@ -13,7 +13,8 @@
     "start-client-server-request-response-tcp": "ts-node -r tsconfig-paths/register src/ClientServerRequestResponseExampleTcp.ts",
     "start-client-server-request-response-websocket": "ts-node -r tsconfig-paths/register src/ClientServerRequestResponseExampleWebSocket.ts",
     "start-client-server-composite-metadata-route": "ts-node -r tsconfig-paths/register src/ClientServerCompositeMetadataRouteExample.ts",
-    "start-client-server-rx-composite-metadata-route": "ts-node -r tsconfig-paths/register src/rxjs/ClientServerCompositeMetadataRouteExample.ts"
+    "start-client-server-rx-composite-metadata-route": "ts-node -r tsconfig-paths/register src/rxjs/ClientServerCompositeMetadataRouteExample.ts",
+    "start-client-server-async-composite-metadata-route": "ts-node -r tsconfig-paths/register src/async/ClientServerCompositeMetadataRouteExample.ts"
   },
   "dependencies": {
     "ws": "~8.2.3",

diff --git a/packages/rsocket-examples/src/async/ClientServerCompositeMetadataRouteExample.ts b/packages/rsocket-examples/src/async/ClientServerCompositeMetadataRouteExample.ts
@@ -5,8 +5,8 @@ import {
   RSocketRequester,
   RSocketResponder,
 } from "@rsocket/messaging";
-import { RxRespondersFactory } from "@rsocket/rxjs";
-import { AsyncRequestersFactory, AsyncRespondersFactory } from "@rsocket/async";
+import { RxRespondersFactory } from "@rsocket/adapter-rxjs";
+import { AsyncRequestersFactory, AsyncRespondersFactory } from "@rsocket/adapter-async";
 import { TcpClientTransport } from "@rsocket/transport-tcp-client";
 import { TcpServerTransport } from "@rsocket/transport-tcp-server";
 import { exit } from "process";

diff --git a/tsconfig.json b/tsconfig.json
@@ -3,6 +3,9 @@
   "compilerOptions": {
     "baseUrl": ".",
     "paths": {
+      "@rsocket/transport-*": [
+        "packages/rsocket-*/src"
+      ],
       "@rsocket/*": [
         "packages/rsocket-*/src"
       ]