Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Effect-TS/effect
/ functions
Functions
8,651 in github.com/Effect-TS/effect
⨍
Functions
8,651
◇
Types & classes
5,147
↓ 1,196 callers
Method
pipe
(this: A)
packages/effect/src/Pipeable.ts:45
↓ 940 callers
Method
get
* Retrieves a Layer for the resources associated with the key.
packages/effect/src/LayerMap.ts:88
↓ 895 callers
Method
succeed
(input: S["~type.make.in"], expected?: S["Type"])
packages/effect/src/testing/TestSchema.ts:123
↓ 654 callers
Method
map
(f: (t: T) => T2)
packages/effect/src/SchemaGetter.ts:79
↓ 642 callers
Method
make
* Constructs a value from the make input representation synchronously. * * **When to use** * * Use when constructor input is trusted or wh
packages/effect/src/Schema.ts:214
↓ 618 callers
Method
push
(item: A)
packages/effect/src/unstable/reactivity/AtomRef.ts:326
↓ 439 callers
Method
set
(this: AtomContext, atom: Writable<R, W>, value: W)
packages/effect/src/unstable/reactivity/Atom.ts:176
↓ 416 callers
Method
provide
* Returns a new {@link Decoding} instance with the given service injected into the decoding effect context. * * **When to use** * * Use wh
packages/effect/src/testing/TestSchema.ts:419
↓ 402 callers
Method
fail
(input: unknown, message: string)
packages/effect/src/testing/TestSchema.ts:135
↓ 396 callers
Method
join
* Reassembles all chunks for a message id into the original binary payload. * * @since 4.0.0
packages/effect/src/unstable/eventlog/EventLogMessage.ts:210
↓ 318 callers
Method
sync
()
packages/effect/src/PubSub.ts:2757
↓ 299 callers
Method
map
(f: (a: B) => C)
packages/effect/src/unstable/reactivity/AtomRef.ts:224
↓ 294 callers
Method
some
(this: AtomContext, atom: Atom<Option.Option<A>>)
packages/effect/src/unstable/reactivity/Atom.ts:178
↓ 254 callers
Method
get
(this: AtomContext, atom: Atom<A>)
packages/effect/src/unstable/reactivity/Atom.ts:162
↓ 217 callers
Method
make
(input: null, options?: Schema.MakeOptions)
packages/effect/src/unstable/rpc/Rpc.ts:54
↓ 204 callers
Method
filter
* Separates SSE retry directives from regular event values. * * @since 4.0.0
packages/effect/src/unstable/encoding/Sse.ts:621
↓ 198 callers
Method
add
(_case: Case)
packages/effect/src/Match.ts:99
↓ 195 callers
Function
f
()
packages/effect/test/Equal.test.ts:1074
↓ 194 callers
Method
has
(_shift: number, hash: number, key: K)
packages/effect/src/internal/hashMap.ts:210
↓ 161 callers
Method
forEach
* Focuses **all elements** of an array-like focus and optionally narrows * to a subset using an element-level optic. * Available only on {@link
packages/effect/src/Optic.ts:841
↓ 136 callers
Method
close
()
packages/effect/src/PubSub.ts:143
↓ 136 callers
Method
fail
(message: string)
packages/effect/src/unstable/encoding/Yaml.ts:317
↓ 128 callers
Method
parse
()
packages/effect/src/unstable/encoding/Yaml.ts:200
↓ 122 callers
Method
tag
* Narrows the focus to the variant of a tagged union with the given * `_tag` value. * * **Details** * * - On a {@link Prism}, returns a
packages/effect/src/Optic.ts:664
↓ 122 callers
Method
toString
()
packages/effect/src/Inspectable.ts:127
↓ 115 callers
Method
replace
(a: A, _: S)
packages/effect/src/Optic.ts:1131
↓ 113 callers
Function
resume
(exit)
packages/effect/src/unstable/rpc/RpcClient.ts:398
↓ 110 callers
Method
of
(this: void, self: Shape)
packages/effect/src/Context.ts:99
↓ 104 callers
Method
addFinalizer
(this: AtomContext, f: () => void)
packages/effect/src/unstable/reactivity/Atom.ts:170
↓ 97 callers
Method
assign
(target: Table, keys: ReadonlyArray<string>, value: unknown)
packages/effect/src/unstable/encoding/Toml.ts:133
↓ 97 callers
Method
take
()
packages/effect/src/PubSub.ts:140
↓ 95 callers
Method
await
(this: Entry<A, E>)
packages/effect/src/Cache.ts:142
↓ 91 callers
Method
merge
* Merge this group with one or more other groups.
packages/effect/src/unstable/rpc/RpcGroup.ts:52
↓ 88 callers
Method
add
* Add one or more procedures to the group.
packages/effect/src/unstable/rpc/RpcGroup.ts:45
↓ 88 callers
Method
find
(method: string, path: string)
packages/effect/src/unstable/http/FindMyWay/internal/router.ts:272
↓ 88 callers
Method
split
* Splits binary event-log message data into numbered chunks. * * @since 4.0.0
packages/effect/src/unstable/eventlog/EventLogMessage.ts:190
↓ 85 callers
Function
deepStrictEqual
(actual: A, expected: A, message?: string, ..._: Array<never>)
packages/effect/test/utils/assert.ts:17
↓ 79 callers
Method
sleep
* Asynchronously sleeps for the specified duration. * * **When to use** * * Use to delay an `Effect` workflow by a duration through this `
packages/effect/src/Clock.ts:148
↓ 79 callers
Function
strictEqual
(actual: A, expected: A, message?: string, ..._: Array<never>)
packages/effect/test/utils/assert.ts:33
↓ 79 callers
Method
transform
(to: L2)
packages/effect/src/Schema.ts:2750
↓ 75 callers
Method
equals
(value: A, next: A)
packages/effect/src/unstable/reactivity/Atom.ts:71
↓ 75 callers
Method
run
(options: ApiDiffOptions)
packages/tools/api-diff/src/ApiDiff.ts:151
↓ 73 callers
Method
all
(path: Router.PathInput, handler: A)
packages/effect/src/unstable/http/FindMyWay/internal/router.ts:99
↓ 73 callers
Method
context
(self: Shape)
packages/effect/src/Context.ts:100
↓ 73 callers
Method
has
(method: string, path: string)
packages/effect/src/unstable/http/FindMyWay/internal/router.ts:258
↓ 73 callers
Method
interrupt
* Creates a terminal reply context that interrupts the supplied request. * * @since 4.0.0
packages/effect/src/unstable/cluster/Reply.ts:113
↓ 71 callers
Function
pipeArguments
(self: A, args: IArguments)
packages/effect/src/Pipeable.ts:564
↓ 70 callers
Function
pipe
()
packages/effect/src/Sink.ts:184
↓ 65 callers
Method
annotate
(annotations: Context.Context<never> | ReadonlyMap<string, unknown>, options?: { readonly overwrite?: bo
packages/effect/src/Cause.ts:264
↓ 64 callers
Method
flip
@internal
packages/effect/src/SchemaAST.ts:2909
↓ 62 callers
Method
combine
(first: Patch, second: Patch)
packages/effect/src/Differ.ts:30
↓ 62 callers
Method
write
(event: AnyEvent)
packages/effect/src/unstable/encoding/Sse.ts:497
↓ 60 callers
Method
check
* Adds one or more `Schema` validation checks to the optic chain. * `getResult` fails when any check fails; `set` passes through unchanged. *
packages/effect/src/Optic.ts:590
↓ 60 callers
Method
sync
()
packages/platform/deno/src/DenoFileSystem.ts:206
↓ 54 callers
Function
assert
(condition: boolean, ...args: ReadonlyArray<any>)
packages/effect/src/Console.ts:141
↓ 53 callers
Function
assertTrue
(self: unknown, message?: string, ..._: Array<never>)
packages/effect/test/utils/assert.ts:71
↓ 53 callers
Method
log
(options: Options<Message>)
packages/effect/src/Logger.ts:66
↓ 53 callers
Method
sync
()
packages/platform/node-shared/src/NodeFileSystem.ts:273
↓ 50 callers
Method
getUnsafe
()
packages/effect/src/unstable/cluster/internal/resourceRef.ts:64
↓ 50 callers
Method
on
(event: "field", listener: (field: Field) => void)
packages/platform/node/src/NodeMultipartParser.ts:42
↓ 50 callers
Method
remove
( _edit: number, _shift: number, hash: number, key: K, removed: { value: boolean } )
packages/effect/src/internal/hashMap.ts:259
↓ 50 callers
Method
value
()
packages/effect/src/unstable/reactivity/AtomRef.ts:210
↓ 49 callers
Method
adjust
* Increments the current clock time by the specified duration. Any effects * that were scheduled to occur on or before the new time will be run in
packages/effect/src/testing/TestClock.ts:100
↓ 49 callers
Method
getRef
(ref: Context.Reference<X>)
packages/effect/src/internal/effect.ts:557
↓ 49 callers
Method
offer
(a: A)
packages/effect/src/PubSub.ts:2709
↓ 49 callers
Method
optionalKey
* Focuses on a key where setting `undefined` **removes** the key from the * struct (or splices the element from an array/tuple). * * **Detail
packages/effect/src/Optic.ts:556
↓ 48 callers
Method
done
()
packages/effect/src/String.ts:1180
↓ 46 callers
Method
clear
()
packages/effect/src/Console.ts:27
↓ 45 callers
Method
toCodecJson
@internal
packages/effect/src/SchemaAST.ts:853
↓ 44 callers
Method
openUnsafe
* Opens the latch synchronously, releasing all fibers waiting on it. * * **When to use** * * Use when synchronous code must open the latch
packages/effect/src/Latch.ts:69
↓ 44 callers
Method
size
()
packages/effect/src/PubSub.ts:94
↓ 42 callers
Method
end
(endTime: bigint, exit: Exit.Exit<unknown, unknown>)
packages/effect/src/Tracer.ts:383
↓ 42 callers
Method
stream
(this: AtomContext, atom: Atom<A>, options?: { readonly withoutInitialValue?: boolean readonly bufferS
packages/effect/src/unstable/reactivity/Atom.ts:180
↓ 41 callers
Function
format
(cron: Cron, options?: { readonly includeSeconds?: boolean | undefined })
packages/effect/src/Cron.ts:643
↓ 41 callers
Function
predicate
(a: number)
packages/effect/test/Option.test.ts:391
↓ 41 callers
Method
send
()
packages/platform/node/test/NodeSocket.test.ts:158
↓ 41 callers
Method
toJSON
()
packages/effect/src/Inspectable.ts:128
↓ 40 callers
Method
addObserver
(cb: (exit: Exit.Exit<A, E>) => void)
packages/effect/src/internal/effect.ts:560
↓ 40 callers
Method
currentTimeMillisUnsafe
* Returns the current Unix time in milliseconds unsafely. * * **When to use** * * Use to read a wall-clock timestamp synchronously when yo
packages/effect/src/Clock.ts:65
↓ 39 callers
Function
make
(value: A)
packages/effect/src/Ref.ts:173
↓ 38 callers
Method
of
* A helper method which can be used for type-safe handler declarations.
packages/effect/src/unstable/ai/Toolkit.ts:84
↓ 37 callers
Method
modify
* Returns a function `(s: S) => S` that applies `f` to the focused value. * If the optic cannot focus, the original `s` is returned unchanged. *
packages/effect/src/Optic.ts:501
↓ 37 callers
Method
next
( ...args: ReadonlyArray<any> )
packages/effect/src/Effect.ts:246
↓ 37 callers
Function
optional
( schema: S )
packages/effect/src/unstable/ai/McpSchema.ts:83
↓ 37 callers
Method
pollUnsafe
()
packages/effect/src/internal/effect.ts:595
↓ 37 callers
Function
throws
(thunk: () => void, error?: string | Error | ((u: unknown) => undefined), ..._: Array<never>)
packages/effect/test/utils/assert.ts:104
↓ 36 callers
Method
execute
( sql: string, params: ReadonlyArray<unknown>, transformRows: (<A extends object>(row: ReadonlyArr
packages/sql/pg/src/PgClient.ts:685
↓ 36 callers
Method
toLayer
* Converts a toolkit into a `Layer` containing handlers for each tool in the * toolkit.
packages/effect/src/unstable/ai/Toolkit.ts:98
↓ 36 callers
Method
use
(f: (service: Shape) => Effect<A, E, R>)
packages/effect/src/Context.ts:101
↓ 34 callers
Method
is
* Attempts to refine the provided value of type `Unbranded<B>`, returning * `true` if the provided value is a valid branded type, `false` otherwise
packages/effect/src/Brand.ts:80
↓ 33 callers
Method
annotate
* Annotate the entity with a value.
packages/effect/src/unstable/cluster/Entity.ts:100
↓ 33 callers
Function
fromChannel
( channel: Channel.Channel< never, E, End<A, L>, NonEmptyReadonlyArray<In>, never, v
packages/effect/src/Sink.ts:235
↓ 33 callers
Method
update
(input: number | bigint)
packages/effect/src/Metric.ts:1780
↓ 32 callers
Function
assertFalse
(self: boolean, message?: string, ..._: Array<never>)
packages/effect/test/utils/assert.ts:75
↓ 32 callers
Method
interruptUnsafe
(fiberId?: number | undefined, annotations?: Context.Context<never> | undefined)
packages/effect/src/internal/effect.ts:573
↓ 32 callers
Function
map
(self: HashSet<V>, f: (value: V) => U)
packages/effect/src/internal/hashSet.ts:151
↓ 32 callers
Method
onInterrupt
(f: (interruptors: ReadonlySet<number>, result: Failure<A, E>) => B)
packages/effect/src/unstable/reactivity/AsyncResult.ts:891
↓ 31 callers
Method
add
* Add a `HttpApiGroup` to the `HttpApi`.
packages/effect/src/unstable/httpapi/HttpApi.ts:66
↓ 31 callers
Function
constant
(a: A)
packages/effect/src/Combiner.ts:266
↓ 31 callers
Method
update
()
packages/effect/test/schema/Schema.test.ts:6698
next →
1–100 of 8,651, ranked by callers