Method schema

packages/effect/src/unstable/cluster/Reply.ts:222–230

* Builds a chunk schema from the streaming success schema of an RPC. * * @since 4.0.0

(
    rpc: R
  )

   * @since 4.0.0
   */
  static schema<R extends Rpc.Any>(
    rpc: R
  ): Schema.declareConstructor<Chunk<R>, Chunk<R>, readonly [Rpc.SuccessExitSchema<R>]> {
    const successSchema = ((rpc as any as Rpc.AnyWithProps).successSchema as RpcSchema.Stream<any, any>).success
    if (!successSchema) {
      return Schema.Never as any
    }
    return this.schemaFrom(successSchema) as any
  }

  /**
   * Builds a chunk schema that validates each success value with the supplied schema.