Skip to content

Commit 04fca05

Browse files
committed
fix: imports in requestChannel impl and async examples
1 parent f30d5b6 commit 04fca05

File tree

4 files changed

+8
-4
lines changed

4 files changed

+8
-4
lines changed

packages/rsocket-adapter-async/src/lib/responders/requestChannel.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ import {
99
Payload,
1010
Requestable,
1111
} from "@rsocket/core";
12-
import { RxRespondersFactory } from "@rsocket/rxjs";
12+
import { RxRespondersFactory } from "@rsocket/adapter-rxjs";
1313
import { eachValueFrom } from "rxjs-for-await";
1414

1515
export default function requestChannel<IN, OUT>(

packages/rsocket-examples/package.json

+2-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,8 @@
1313
"start-client-server-request-response-tcp": "ts-node -r tsconfig-paths/register src/ClientServerRequestResponseExampleTcp.ts",
1414
"start-client-server-request-response-websocket": "ts-node -r tsconfig-paths/register src/ClientServerRequestResponseExampleWebSocket.ts",
1515
"start-client-server-composite-metadata-route": "ts-node -r tsconfig-paths/register src/ClientServerCompositeMetadataRouteExample.ts",
16-
"start-client-server-rx-composite-metadata-route": "ts-node -r tsconfig-paths/register src/rxjs/ClientServerCompositeMetadataRouteExample.ts"
16+
"start-client-server-rx-composite-metadata-route": "ts-node -r tsconfig-paths/register src/rxjs/ClientServerCompositeMetadataRouteExample.ts",
17+
"start-client-server-async-composite-metadata-route": "ts-node -r tsconfig-paths/register src/async/ClientServerCompositeMetadataRouteExample.ts"
1718
},
1819
"dependencies": {
1920
"ws": "~8.2.3",

packages/rsocket-examples/src/async/ClientServerCompositeMetadataRouteExample.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@ import {
55
RSocketRequester,
66
RSocketResponder,
77
} from "@rsocket/messaging";
8-
import { RxRespondersFactory } from "@rsocket/rxjs";
9-
import { AsyncRequestersFactory, AsyncRespondersFactory } from "@rsocket/async";
8+
import { RxRespondersFactory } from "@rsocket/adapter-rxjs";
9+
import { AsyncRequestersFactory, AsyncRespondersFactory } from "@rsocket/adapter-async";
1010
import { TcpClientTransport } from "@rsocket/transport-tcp-client";
1111
import { TcpServerTransport } from "@rsocket/transport-tcp-server";
1212
import { exit } from "process";

tsconfig.json

+3
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,9 @@
33
"compilerOptions": {
44
"baseUrl": ".",
55
"paths": {
6+
"@rsocket/transport-*": [
7+
"packages/rsocket-*/src"
8+
],
69
"@rsocket/*": [
710
"packages/rsocket-*/src"
811
]

0 commit comments

Comments
 (0)