Function Stream

packages/rpc/src/RpcSchema.ts:63–93

(
  { failure, success }: {
    readonly failure: E
    readonly success: A
  }
)

 * @category Stream
 */
export const Stream = <A extends Schema.Schema.Any, E extends Schema.Schema.All>(
  { failure, success }: {
    readonly failure: E
    readonly success: A
  }
): Stream<A, E> =>
  Object.assign(
    Schema.declare(
      [success, failure],
      {
        decode: (success, failure) =>
          parseStream(
            ParseResult.decodeUnknown(Schema.ChunkFromSelf(success)),
            ParseResult.decodeUnknown(failure)
          ),
        encode: (success, failure) =>
          parseStream(
            ParseResult.encodeUnknown(Schema.ChunkFromSelf(success)),
            ParseResult.encodeUnknown(failure)
          )
      },
      {
        schemaId: StreamSchemaId,
        [StreamSchemaId]: { success, failure }
      }
    ),
    {
      success,
      failure
    }
  )

const isStream = (u: unknown): u is Stream_.Stream<unknown, unknown> => hasProperty(u, Stream_.StreamTypeId)