Skip to content

Commit 523faec

Browse files
committed
Review feedback
1 parent f5601d0 commit 523faec

File tree

3 files changed

+14
-9
lines changed

3 files changed

+14
-9
lines changed

.changeset/happy-taxis-lick.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
---
2+
'@powersync/service-image': minor
3+
---
4+
5+
Support WebSocket requests to be encoded as JSON, which will enable more SDKs to use WebSockets as a transport protocol when receiving sync lines.

.changeset/wild-maps-brake.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
---
22
'@powersync/service-rsocket-router': patch
33
'@powersync/service-errors': patch
4-
'@powersync/service-core': patch
4+
'@powersync/service-core': minor
55
---
66

77
Allow RSocket request payload to be encoded as JSON

packages/rsocket-router/src/router/ReactiveSocketRouter.ts

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,14 @@ import {
1818
SocketResponder
1919
} from './types.js';
2020

21+
export interface ReactiveStreamRequest {
22+
payload: Payload;
23+
metadataMimeType: string;
24+
dataMimeType: string;
25+
initialN: number;
26+
responder: SocketResponder;
27+
}
28+
2129
export class ReactiveSocketRouter<C> {
2230
constructor(protected options?: ReactiveSocketRouterOptions<C>) {}
2331

@@ -123,14 +131,6 @@ export class ReactiveSocketRouter<C> {
123131
}
124132
}
125133

126-
export interface ReactiveStreamRequest {
127-
payload: Payload;
128-
metadataMimeType: string;
129-
dataMimeType: string;
130-
initialN: number;
131-
responder: SocketResponder;
132-
}
133-
134134
export async function handleReactiveStream<Context>(
135135
context: Context,
136136
request: ReactiveStreamRequest,

0 commit comments

Comments
 (0)