<Self, S extends Hyperlink.Spec, HSelf, R = never>(
tag: Hyperlink.NodeBoundTag<Self, S, HSelf>,
impl:
| Hyperlink.ImplOf<S>
| Hyperlink.BuiltHyperlink<S, R>
| Effect.Effect<
Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>,
never,
R
>,
options?: ListenOptions
): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>
<
Node extends AnyNode & { readonly [catalogSym]?: unknown },
Serves extends ServeLayerList
>(
node: Node,
serves: Serves & ServesForCatalog<CatalogROut<Node>, Serves>,
options?: ListenOptions
): Layer.Layer<
Layer.Success<Serves[number]> | ListenNode,
never,
Layer.Services<Serves[number]>
>Neutral catalog spine (C2) — no transport bind. Prefer unix / http / ws.
IpcSocket, Http, WebSocket, address-less, nameless, and Tag+impl fail with ListenUseProtocol → use the matching protocol entry.
export function function listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R> (+1 overload)Neutral catalog spine (C2) — no transport bind. Prefer
unix
/
http
/
ws
.
**IpcSocket, Http, WebSocket, address-less, nameless, and Tag+impl fail with
ListenUseProtocol
** → use the matching protocol entry.
listen<
function (type parameter) Self in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>Self,
function (type parameter) S in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>S extends import HyperlinkHyperlink.type Hyperlink.Spec = /*unresolved*/ anySpec,
function (type parameter) HSelf in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>HSelf,
function (type parameter) R in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>R = never,
>(
tag: Hyperlink.NodeBoundTag<Self, S, HSelf>tag: import HyperlinkHyperlink.type Hyperlink.NodeBoundTag = /*unresolved*/ anyNodeBoundTag<function (type parameter) Self in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>Self, function (type parameter) S in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>S, function (type parameter) HSelf in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>HSelf>,
impl: anyimpl:
| import HyperlinkHyperlink.type Hyperlink.ImplOf = /*unresolved*/ anyImplOf<function (type parameter) S in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>S>
| import HyperlinkHyperlink.type Hyperlink.BuiltHyperlink = /*unresolved*/ anyBuiltHyperlink<function (type parameter) S in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>S, function (type parameter) R in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>R>
| import EffectEffect.interface Effect<out A, out E = never, out R = never>The Effect interface defines a value that lazily describes a workflow or
job. The workflow requires some context R, and may fail with an error of
type E, or succeed with a value of type A.
When to use
Use when you need to represent a lazy, composable workflow that can require
services, fail with a typed error, or succeed with a typed value.
Details
Effect values model resourceful interaction with the outside world,
including synchronous, asynchronous, concurrent, and parallel interaction.
They use a fiber-based concurrency model, with built-in support for
scheduling, fine-grained interruption, structured concurrency, and high
scalability.
To run an Effect value, you need a Runtime, which is a type that is
capable of executing Effect values.
Effect<
import HyperlinkHyperlink.type Hyperlink.ImplOf = /*unresolved*/ anyImplOf<function (type parameter) S in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>S> | import HyperlinkHyperlink.type Hyperlink.BuiltHyperlink = /*unresolved*/ anyBuiltHyperlink<function (type parameter) S in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>S, function (type parameter) R in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>R>,
never,
function (type parameter) R in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>R
>,
options: anyoptions?: import ListenOptionsListenOptions,
): import LayerLayer.interface Layer<in ROut, out E = never, out RIn = never>A Layer describes how to build one or more services for dependency injection.
When to use
Use to model construction of application services for dependency injection,
especially when services have dependencies, can fail during construction, or
need scoped setup and release.
Details
A Layer<ROut, E, RIn> represents ROut as the services this layer
provides, E as the possible errors during layer construction, and RIn as
the services this layer requires as dependencies.
Layer<function (type parameter) Self in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>Self | import HyperlinkHyperlink.type Hyperlink.Local = /*unresolved*/ anyLocal<function (type parameter) Self in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>Self> | import ListenNodeListenNode, never, function (type parameter) R in listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R>R>;
export function function listen<Node extends AnyNode & {}, Serves extends ServeLayerList>(node: Node, serves: Serves & ServesForCatalog<CatalogROut<Node>, Serves>, options?: ListenOptions): Layer.Layer<Layer.Success<Serves[number]> | ListenNode, never, Layer.Services<Serves[number]>> (+1 overload)Neutral catalog spine (C2) — no transport bind. Prefer
unix
/
http
/
ws
.
**IpcSocket, Http, WebSocket, address-less, nameless, and Tag+impl fail with
ListenUseProtocol
** → use the matching protocol entry.
listen<
function (type parameter) Node in listen<Node extends AnyNode & {}, Serves extends ServeLayerList>(node: Node, serves: Serves & ServesForCatalog<CatalogROut<Node>, Serves>, options?: ListenOptions): Layer.Layer<Layer.Success<Serves[number]> | ListenNode, never, Layer.Services<Serves[number]>>Node extends import AnyNodeAnyNode & { readonly [import catalogSymcatalogSym]?: unknown },
function (type parameter) Serves in listen<Node extends AnyNode & {}, Serves extends ServeLayerList>(node: Node, serves: Serves & ServesForCatalog<CatalogROut<Node>, Serves>, options?: ListenOptions): Layer.Layer<Layer.Success<Serves[number]> | ListenNode, never, Layer.Services<Serves[number]>>Serves extends import ServeLayerListServeLayerList,
>(
node: Node extends AnyNode & {}node: function (type parameter) Node in listen<Node extends AnyNode & {}, Serves extends ServeLayerList>(node: Node, serves: Serves & ServesForCatalog<CatalogROut<Node>, Serves>, options?: ListenOptions): Layer.Layer<Layer.Success<Serves[number]> | ListenNode, never, Layer.Services<Serves[number]>>Node,
serves: anyserves: function (type parameter) Serves in listen<Node extends AnyNode & {}, Serves extends ServeLayerList>(node: Node, serves: Serves & ServesForCatalog<CatalogROut<Node>, Serves>, options?: ListenOptions): Layer.Layer<Layer.Success<Serves[number]> | ListenNode, never, Layer.Services<Serves[number]>>Serves & import ServesForCatalogServesForCatalog<import CatalogROutCatalogROut<function (type parameter) Node in listen<Node extends AnyNode & {}, Serves extends ServeLayerList>(node: Node, serves: Serves & ServesForCatalog<CatalogROut<Node>, Serves>, options?: ListenOptions): Layer.Layer<Layer.Success<Serves[number]> | ListenNode, never, Layer.Services<Serves[number]>>Node>, function (type parameter) Serves in listen<Node extends AnyNode & {}, Serves extends ServeLayerList>(node: Node, serves: Serves & ServesForCatalog<CatalogROut<Node>, Serves>, options?: ListenOptions): Layer.Layer<Layer.Success<Serves[number]> | ListenNode, never, Layer.Services<Serves[number]>>Serves>,
options: anyoptions?: import ListenOptionsListenOptions,
): import LayerLayer.interface Layer<in ROut, out E = never, out RIn = never>A Layer describes how to build one or more services for dependency injection.
When to use
Use to model construction of application services for dependency injection,
especially when services have dependencies, can fail during construction, or
need scoped setup and release.
Details
A Layer<ROut, E, RIn> represents ROut as the services this layer
provides, E as the possible errors during layer construction, and RIn as
the services this layer requires as dependencies.
Layer<
import LayerLayer.type Success<T extends Layer.Any> =
T extends Layer.Layer<
infer _ROut,
infer _E,
infer _RIn
>
? _ROut
: never
Extracts the service output type (ROut) from a Layer type.
When to use
Use to derive the services provided by an existing or generic Layer without
restating its ROut type parameter.
Success<function (type parameter) Serves in listen<Node extends AnyNode & {}, Serves extends ServeLayerList>(node: Node, serves: Serves & ServesForCatalog<CatalogROut<Node>, Serves>, options?: ListenOptions): Layer.Layer<Layer.Success<Serves[number]> | ListenNode, never, Layer.Services<Serves[number]>>Serves[number]> | import ListenNodeListenNode,
never,
import LayerLayer.type Services<T extends Layer.Any> =
T extends infer L
? L extends Layer.Layer<
infer _ROut,
infer _E,
infer _RIn
>
? _RIn
: never
: never
Extracts the service requirements (RIn) from a Layer type.
When to use
Use to derive the dependency requirements of a generic or inferred Layer
without restating its RIn type parameter.
Services<function (type parameter) Serves in listen<Node extends AnyNode & {}, Serves extends ServeLayerList>(node: Node, serves: Serves & ServesForCatalog<CatalogROut<Node>, Serves>, options?: ListenOptions): Layer.Layer<Layer.Success<Serves[number]> | ListenNode, never, Layer.Services<Serves[number]>>Serves[number]>
>;
export function function listen<Self, S extends Hyperlink.Spec, HSelf, R = never>(tag: Hyperlink.NodeBoundTag<Self, S, HSelf>, impl: Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R> | Effect.Effect<Hyperlink.ImplOf<S> | Hyperlink.BuiltHyperlink<S, R>, never, R>, options?: ListenOptions): Layer.Layer<Self | Hyperlink.Local<Self> | ListenNode, never, R> (+1 overload)Neutral catalog spine (C2) — no transport bind. Prefer
unix
/
http
/
ws
.
**IpcSocket, Http, WebSocket, address-less, nameless, and Tag+impl fail with
ListenUseProtocol
** → use the matching protocol entry.
listen(
nodeOrTag: anynodeOrTag: import AnyNodeAnyNode | import HyperlinkHyperlink.type Hyperlink.PipeableTag = /*unresolved*/ anyPipeableTag,
_servesOrImpl: any_servesOrImpl?:
| import LayerLayer.interface Layer<in ROut, out E = never, out RIn = never>A Layer describes how to build one or more services for dependency injection.
When to use
Use to model construction of application services for dependency injection,
especially when services have dependencies, can fail during construction, or
need scoped setup and release.
Details
A Layer<ROut, E, RIn> represents ROut as the services this layer
provides, E as the possible errors during layer construction, and RIn as
the services this layer requires as dependencies.
Layer<never, any, never>
| import ServeLayerListServeLayerList
| object,
_options: any_options?: import ListenOptionsListenOptions,
): import LayerLayer.interface Layer<in ROut, out E = never, out RIn = never>A Layer describes how to build one or more services for dependency injection.
When to use
Use to model construction of application services for dependency injection,
especially when services have dependencies, can fail during construction, or
need scoped setup and release.
Details
A Layer<ROut, E, RIn> represents ROut as the services this layer
provides, E as the possible errors during layer construction, and RIn as
the services this layer requires as dependencies.
Layer<
never,
| import UnaddressedNodeUnaddressedNode
| import AddressLessClaimLostAddressLessClaimLost
| import ListenTagNodeRequiredListenTagNodeRequired
| import ListenUseProtocolListenUseProtocol,
unknown
> {
if (import isHyperlinkTagArgisHyperlinkTagArg(nodeOrTag: anynodeOrTag)) {
const const tag: anytag = nodeOrTag: anynodeOrTag;
const const tagKey: stringtagKey = (() => {
const const key: unknownkey = (const tag: anytag as unknown as { readonly key?: unknownkey?: unknown }).key?: unknownkey;
return typeof const key: unknownkey === "string" ? const key: stringkey : "unknown";
})();
const const bound: anybound = import HyperlinkHyperlink.nodeOf(const tag: anytag);
const const fleet: anyfleet = import HyperlinkHyperlink.nodesOf(
const tag: anytag as unknown as import HyperlinkHyperlink.type Hyperlink.HyperlinkTag = /*unresolved*/ anyHyperlinkTag<unknown, import HyperlinkHyperlink.type Hyperlink.Spec = /*unresolved*/ anySpec>,
);
if (const bound: anybound === var undefinedundefined) {
return import failListenTagNodefailListenTagNode({
tag: stringtag: const tagKey: stringtagKey,
reason: stringreason: const fleet: anyfleet.length > 1 ? "ambiguous" : "missing",
count: anycount: const fleet: anyfleet.length,
});
}
if (import isIpcListenNodeisIpcListenNode(const bound: anybound as import AnyNodeAnyNode)) {
return import failUseProtocolfailUseProtocol(
"unix",
`Tag "${const tagKey: stringtagKey}" is bound to an IpcSocket Node`,
);
}
if (import isHttpListenNodeisHttpListenNode(const bound: anybound as import AnyNodeAnyNode)) {
return import failUseProtocolfailUseProtocol(
"http",
`Tag "${const tagKey: stringtagKey}" is bound to an Http Node`,
);
}
if (import isWsListenNodeisWsListenNode(const bound: anybound as import AnyNodeAnyNode)) {
return import failUseProtocolfailUseProtocol(
"ws",
`Tag "${const tagKey: stringtagKey}" is bound to a WebSocket Node`,
);
}
return import failUseProtocolfailUseProtocol(
"unix",
`Tag "${const tagKey: stringtagKey}" has no protocol-bound Node — use Node.unix / Node.http / Node.ws`,
);
}
const const node: AnyNodenode = nodeOrTag: anynodeOrTag as import AnyNodeAnyNode;
if (import isPrototypeNodeisPrototypeNode(const node: AnyNodenode)) {
return import unaddressedLayerunaddressedLayer(const node: AnyNodenode.key);
}
if (import isIpcListenNodeisIpcListenNode(const node: AnyNodenode) || import isDynamicInstanceNodeisDynamicInstanceNode(const node: AnyNodenode)) {
return import failUseProtocolfailUseProtocol(
"unix",
`node "${const node: AnyNodenode.key}" needs IpcSocket bind`,
);
}
if (import isHttpListenNodeisHttpListenNode(const node: AnyNodenode)) {
return import failUseProtocolfailUseProtocol("http", `node "${const node: AnyNodenode.key}" needs Http bind`);
}
if (import isWsListenNodeisWsListenNode(const node: AnyNodenode)) {
return import failUseProtocolfailUseProtocol("ws", `node "${const node: AnyNodenode.key}" needs WebSocket bind`);
}
return import failUseProtocolfailUseProtocol(
"unix",
`node "${const node: AnyNodenode.key}" — use Node.unix / Node.http / Node.ws`,
);
}