From 04fca05bd9c754a2fef404d139ea5325b544795c Mon Sep 17 00:00:00 2001 From: Kevin Viglucci Date: Wed, 12 Jan 2022 09:34:37 -0600 Subject: [PATCH] fix: imports in requestChannel impl and async examples --- .../src/lib/responders/requestChannel.ts | 2 +- packages/rsocket-examples/package.json | 3 ++- .../src/async/ClientServerCompositeMetadataRouteExample.ts | 4 ++-- tsconfig.json | 3 +++ 4 files changed, 8 insertions(+), 4 deletions(-) diff --git a/packages/rsocket-adapter-async/src/lib/responders/requestChannel.ts b/packages/rsocket-adapter-async/src/lib/responders/requestChannel.ts index a3988ce0..555f7b35 100644 --- 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( diff --git a/packages/rsocket-examples/package.json b/packages/rsocket-examples/package.json index db1bc733..f78cf19f 100644 --- 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 index c6b3f8da..fc50da84 100644 --- 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 index c83a05a5..cf9065e8 100644 --- a/tsconfig.json +++ b/tsconfig.json @@ -3,6 +3,9 @@ "compilerOptions": { "baseUrl": ".", "paths": { + "@rsocket/transport-*": [ + "packages/rsocket-*/src" + ], "@rsocket/*": [ "packages/rsocket-*/src" ]