Skip to content
Effect Days 2026 Get your ticket

RpcSchema

6 exports Added in v1.0.0 Source

Stream

Signature

declare function getStreamSchemas(ast: AST): Option<{
readonly failure: All;
readonly success: Any;
}>

Signature

declare function isStreamSchema(schema: All): schema is Stream<any, any>

Signature

declare function isStreamSerializable(schema: Any): boolean

Stream

Added in v1.0.0 Source

Signature

declare const Stream: <A extends Any, E extends All>(__namedParameters: {
readonly failure: E;
readonly success: A;
}) => Stream<A, E>

Stream interface

Added in v1.0.0 Source

Signature

interface Stream<A extends Schema.Schema.Any, E extends Schema.Schema.All> extends Schema<Stream_.Stream<A["Type"], E["Type"]>, Stream_.Stream<A["Encoded"], E["Encoded"]>, A["Context"] | E["Context"]> {
readonly failure: E;
readonly success: A;
}

Signature

declare const StreamSchemaId: unique symbol