EventLogRemote
Change
Since v1.0.0 Source
Signature
declare class RemoteAdditions extends { readonly _tag: "RemoveAdditions"; readonly entries: readonly Array<RemoteEntry>;} { constructor(...args: [props: { readonly _tag?: "RemoveAdditions"; readonly entries: readonly Array<RemoteEntry>; }, options?: MakeOptions]);}Construtors
Layers
Since v1.0.0 Source
Signature
declare function layerWebSocket(url: string, options?: { readonly disablePing?: boolean;}): Layer<never, never, any> Since v1.0.0 Source
Signature
declare function layerWebSocketBrowser(url: string, options?: { readonly disablePing?: boolean;}): Layer<never, never, EventLog>Models
EventLogRemote
interface Since v1.0.0 Source
Signature
interface EventLogRemote { readonly changes: (identity: any, startSequence: number) => Effect<ReadonlyMailbox<RemoteEntry>, never, Scope>; readonly id: any; readonly write: (identity: any, entries: readonly Array<Entry>) => Effect<void>;}Protocol
Signature
declare class Ack extends { readonly _tag: "Ack"; readonly id: number; readonly sequenceNumbers: readonly Array<number>;} { constructor(...args: [props: { readonly _tag?: "Ack"; readonly id: number; readonly sequenceNumbers: readonly Array<number>; }, options?: MakeOptions]);}Signature
declare class Changes extends { readonly _tag: "Changes"; readonly entries: readonly Array<{ [key: string]: any; }>; readonly publicKey: string;} { constructor(...args: [props: { readonly _tag?: "Changes"; readonly entries: readonly Array<{ [key: string]: any; }>; readonly publicKey: string; }, options?: MakeOptions]);} Since v1.0.0 Source
Signature
declare class ChunkedMessage extends { [key: string]: any;} { [key: string]: any; constructor(...args: [props?: { [key: string]: any; }, options?: MakeOptions]); static join(map: Map<number, { bytes: number; count: number; readonly parts: Array<Uint8Array<ArrayBufferLike>>; }>, part: ChunkedMessage): Uint8Array<ArrayBufferLike> | undefined; static split(id: number, data: Uint8Array): readonly Array<ChunkedMessage>;} Since v1.0.0 Source
Signature
declare const decodeRequest: (input: any, options?: ParseOptions) => any Since v1.0.0 Source
Signature
declare const decodeResponse: (input: any, options?: ParseOptions) => any Since v1.0.0 Source
Signature
declare const encodeRequest: (input: any, options?: ParseOptions) => any Since v1.0.0 Source
Signature
declare const encodeResponse: (input: any, options?: ParseOptions) => anySignature
declare class Hello extends { [key: string]: any;} { [key: string]: any; constructor(...args: [props?: { [key: string]: any; }, options?: MakeOptions]);}Signature
declare class Ping extends { readonly _tag: "Ping"; readonly id: number;} { constructor(...args: [props: { readonly _tag?: "Ping"; readonly id: number; }, options?: MakeOptions]);}Signature
declare class Pong extends { readonly _tag: "Pong"; readonly id: number;} { constructor(...args: [props: { readonly _tag?: "Pong"; readonly id: number; }, options?: MakeOptions]);} Since v1.0.0 Source
Signature
declare const ProtocolRequest: Union<readonly Array<Constraint>> Since v1.0.0 Source
Signature
declare const ProtocolRequestMsgPack: any Since v1.0.0 Source
Signature
declare const ProtocolResponse: Union<readonly Array<Constraint>> Since v1.0.0 Source
Signature
declare const ProtocolResponseMsgPack: any Since v1.0.0 Source
Signature
declare class RequestChanges extends { readonly _tag: "RequestChanges"; readonly publicKey: string; readonly startSequence: number;} { constructor(...args: [props: { readonly _tag?: "RequestChanges"; readonly publicKey: string; readonly startSequence: number; }, options?: MakeOptions]);} Since v1.0.0 Source
Signature
declare class StopChanges extends { readonly _tag: "StopChanges"; readonly publicKey: string;} { constructor(...args: [props: { readonly _tag?: "StopChanges"; readonly publicKey: string; }, options?: MakeOptions]);} Since v1.0.0 Source
Signature
declare class WriteEntries extends { [key: string]: any;} { [key: string]: any; constructor(...args: [props?: { [key: string]: any; }, options?: MakeOptions]);}