diff --git a/packages/rpc/src/RpcSerialization.ts b/packages/rpc/src/RpcSerialization.ts index f65fda78e8..2ca56e431c 100644 --- a/packages/rpc/src/RpcSerialization.ts +++ b/packages/rpc/src/RpcSerialization.ts @@ -122,4 +122,4 @@ export const layerNdjson: Layer.Layer = Layer.effect(RpcSerial * @since 1.0.0 * @category serialization */ -export const layeMsgPack: Layer.Layer = Layer.succeed(RpcSerialization, msgPack) +export const layerMsgPack: Layer.Layer = Layer.succeed(RpcSerialization, msgPack) diff --git a/packages/rpc/src/RpcServer.ts b/packages/rpc/src/RpcServer.ts index 97d85cb6cb..0c14817b04 100644 --- a/packages/rpc/src/RpcServer.ts +++ b/packages/rpc/src/RpcServer.ts @@ -623,6 +623,7 @@ export class Protocol extends Context.Tag("@effect/rpc/RpcServer/Protocol") Effect.Effect readonly end: (clientId: number) => Effect.Effect readonly supportsAck: boolean + readonly supportsTransferables: boolean }>() {} /** @@ -666,7 +667,8 @@ export const makeProtocolSocketServer = Effect.gen(function*() { end(_clientId) { return Effect.void }, - supportsAck: true + supportsAck: true, + supportsTransferables: false }) }) @@ -731,7 +733,8 @@ export const makeProtocolWithHttpAppWebsocket: Effect.Effect< end(_clientId) { return Effect.void }, - supportsAck: true + supportsAck: true, + supportsTransferables: false }) return { protocol, httpApp } as const @@ -848,7 +851,8 @@ export const makeProtocolWithHttpApp: Effect.Effect< if (!client) return Effect.void return client.end }, - supportsAck: false + supportsAck: false, + supportsTransferables: false }) return { protocol, httpApp } as const