Function toChannelMap

repos/effect/packages/effect/src/unstable/socket/Socket.ts:386–435

(
  self: Socket,
  f: (data: Uint8Array | string) => A
)

 * Typed error for an unsupported or failed in-place TLS upgrade.
 *
 * @category errors
 * @since 4.0.0
 */
export class SocketUpgradeError extends Schema.Error<SocketUpgradeError>(
  "effect/socket/Socket/SocketUpgradeError"
)({
  _tag: Schema.tag("SocketUpgradeError"),
  cause: Schema.optional(Schema.Defect())
}) {
  /**
   * An upgrade implementation for transports that cannot wrap the connection
   * with TLS.
   *
   * @since 4.0.0
   */
  static readonly unsupported: Reader["upgrade"] = () =>
    Effect.fail(new SocketError({ reason: new SocketUpgradeError({}) }))

  override get message() {
    return this.cause === undefined
      ? `Socket does not support TLS upgrade`
      : `An error occurred during TLS upgrade`
  }
}

/**
 * Typed error for a socket close, carrying the close code and optional close
 * reason.
 *
 * **Details**
 *
 * Sockets never classify closes: any close, whatever the code, fails the
 * reader with a `SocketError` wrapping this reason. Consumers that treat a
 * close as normal catch it.
 *
 * @category errors
 * @since 4.0.0
 */
export class SocketCloseError extends Schema.Error<SocketCloseError>("effect/socket/Socket/SocketCloseError")({
  _tag: Schema.tag("SocketCloseError"),
  code: Schema.Int,
  closeReason: Schema.optional(Schema.String)
}) {
  override get message() {
    if (this.closeReason) {
      return `${this.code}: ${this.closeReason}`
    }
    return `${this.code}`
  }
}

/**
 * Schema for all socket-specific error reasons.