MCPcopy Create free account

hub / github.com/Effect-TS/effect / functions

Functions8,651 in github.com/Effect-TS/effect

⨍ Functions 8,651◇ Types & classes 5,147
↓ 30 callersMethodaddEventListener
( event: string, f: (event: A) => void, options?: { readonly capture?: boolean readonl
packages/effect/src/Stream.ts:1354
↓ 30 callersMethodofferUnsafe
(elements: Iterable<A>, deferred: Deferred.Deferred<boolean>)
packages/effect/src/PubSub.ts:2427
↓ 29 callersFunctiongraphImpl
( graph: Graph<N, E, T> | MutableGraph<N, E, T> )
packages/effect/src/Graph.ts:227
↓ 29 callersFunctionmakeFilter
( filter: (input: T, ast: AST, options: ParseOptions) => Schema.FilterOutput, annotations?: Schema.Annotat
packages/effect/src/SchemaAST.ts:3214
↓ 27 callersMethodbuild
@internal
packages/effect/src/Layer.ts:56
↓ 27 callersMethodcloseUnsafe
* Closes the latch synchronously so future waiters suspend again. * * **When to use** * * Use when synchronous code must close the latch i
packages/effect/src/Latch.ts:105
↓ 27 callersMethodexec
(sql: string, ...params: ReadonlyArray<unknown>)
packages/sql/sqlite-do/test/Client.test.ts:39
↓ 27 callersMethodisEmpty
()
packages/effect/src/PubSub.ts:92
↓ 27 callersMethodmiddleware
* Add an `RpcMiddleware` to this procedure.
packages/effect/src/unstable/rpc/Rpc.ts:134
↓ 27 callersMethodrelease
* Releases the specified number of permits and returns the resulting * available permits. * * **When to use** * * Use to manually retur
packages/effect/src/Semaphore.ts:154
↓ 27 callersFunctiontoJson
(input: unknown)
packages/effect/src/Inspectable.ts:153
↓ 26 callersMethoddecodeUnknownSync
()
packages/effect/test/schema/Schema.test.ts:10215
↓ 26 callersFunctionrunFork
(effect: Effect.Effect<A, E, R>, options?: Effect.RunOptions)
packages/effect/src/ManagedRuntime.ts:347
↓ 25 callersMethodabort
()
packages/effect/src/SchemaAST.ts:3153
↓ 25 callersFunctionassertNone
(option: Option.Option<A>, ..._: Array<never>)
packages/effect/test/utils/assert.ts:147
↓ 25 callersFunctioncallback
( f: (queue: Queue.Queue<A, E | Cause.Done>) => Effect.Effect<unknown, E, R | Scope.Scope>, options?: {
packages/effect/src/Stream.ts:694
↓ 25 callersMethodinvalidate
* Invalidates the resource associated with the key.
packages/effect/src/LayerMap.ts:98
↓ 25 callersFunctiontryPromise
( method: string, pathOrDescriptor: string | number | undefined, evaluate: (signal: AbortSignal) => Prom
packages/platform/deno/src/DenoFileSystem.ts:16
↓ 24 callersFunctionassertSome
( option: Option.Option<A>, expected: A, ..._: Array<never> )
packages/effect/test/utils/assert.ts:151
↓ 24 callersFunctionidentity
()
packages/effect/src/Channel.ts:1190
↓ 24 callersMethodonce
(this: AtomContext, atom: Atom<A>)
packages/effect/src/unstable/reactivity/Atom.ts:169
↓ 24 callersMethodorElse
(orElse: LazyArg<B>)
packages/effect/src/unstable/reactivity/AsyncResult.ts:898
↓ 24 callersMethodremoveEventListener
( event: string, f: (event: A) => void, options?: { readonly capture?: boolean } | boole
packages/effect/src/Stream.ts:1364
↓ 24 callersFunctionrun
()
packages/effect/src/FiberSet.ts:496
↓ 24 callersMethodtakeAll
()
packages/effect/src/PubSub.ts:142
↓ 24 callersMethodtext
()
packages/effect/src/unstable/http/HttpClient.ts:1733
↓ 24 callersMethodwithPermits
* Runs an effect with the given number of permits and releases the permits * when the effect completes. * * **When to use** * * Use to
packages/effect/src/Semaphore.ts:82
↓ 23 callersMethodat
* Focuses on a key only if it exists (`Object.hasOwn`). Both * `getResult` and `replaceResult` fail when the key is absent. * * **Details**
packages/effect/src/Optic.ts:703
↓ 23 callersFunctionnotFound
(method: string, path: string)
packages/effect/src/FileSystem.ts:764
↓ 23 callersFunctiontransform
(f: (e: E) => T)
packages/effect/src/SchemaGetter.ts:521
↓ 22 callersFunctiondecodeTo
( to: To, transformation?: { readonly decode: SchemaGetter.Getter<To["Encoded"], From["Type"], RD>
packages/effect/src/Schema.ts:5580
↓ 22 callersMethodencodeSync
()
packages/effect/typetest/schema/Schema.tst.ts:1966
↓ 21 callersMethodsubscribe
(this: AtomContext, atom: Atom<A>, f: (_: A) => void, options?: { readonly immediate?: boolean })
packages/effect/src/unstable/reactivity/Atom.ts:188
↓ 20 callersFunctionfromTransform
( transform: ( upstream: Pull.Pull<NonEmptyReadonlyArray<In>, never, void>, scope: Scope.Scope ) =
packages/effect/src/Sink.ts:302
↓ 20 callersMethodhandle
* Add the implementation for an `Event` to a `Handlers` group.
packages/effect/src/unstable/eventlog/EventLog.ts:283
↓ 20 callersMethodrequest
()
packages/effect/src/unstable/http/HttpServerError.ts:60
↓ 20 callersMethodshutdown
()
packages/effect/src/PubSub.ts:2581
↓ 20 callersMethodsubscribe
()
packages/effect/src/PubSub.ts:98
↓ 20 callersFunctiontoImpl
( self: Command<Name, Input, ContextInput, E, R> )
packages/effect/src/unstable/cli/internal/command.ts:67
↓ 19 callersFunctionfromPull
( effect: Effect.Effect<Pull.Pull<OutElem, OutErr, OutDone, EnvX>, EX, Env> )
packages/effect/src/Channel.ts:379
↓ 19 callersMethodgroup
(...args: ReadonlyArray<any>)
packages/effect/src/Console.ts:34
↓ 19 callersMethodofferAll
(as: Iterable<A>)
packages/effect/src/PubSub.ts:2726
↓ 19 callersMethodomit
* Focuses on all keys **except** the specified ones. * * **Details** * * - On a {@link Lens}, returns a Lens. * - On an {@link Optional
packages/effect/src/Optic.ts:768
↓ 19 callersMethodremove
()
packages/effect/src/unstable/reactivity/AtomRegistry.ts:792
↓ 18 callersMethodcompile
( statement: Fragment, withoutTransform?: boolean, placeholderOverride?: (u: unknown) => string
packages/effect/src/unstable/sql/Statement.ts:814
↓ 18 callersMethodcompleteUnsafe
( exit: Exit.Exit< [R] extends [Request<infer _A, infer _E, infer _R>] ? _A : never, [R] exten
packages/effect/src/Request.ts:574
↓ 18 callersMethoderror
(...args: ReadonlyArray<any>)
packages/effect/src/Console.ts:33
↓ 18 callersMethodread
(size?: number)
packages/platform/node/src/NodeMultipartParser.ts:57
↓ 18 callersMethodresult
* Constructs a branded type from a value of type `Unbranded<B>`, returning * `Success<B>` if the provided value is valid, `Failure<BrandError>`
packages/effect/src/Brand.ts:75
↓ 18 callersMethodtoCodecStringTree
@internal
packages/effect/src/SchemaAST.ts:1077
↓ 17 callersFunctionclient
()
packages/effect/src/unstable/cluster/Entity.ts:268
↓ 17 callersFunctionerrorWithPath
(message: string, path: ReadonlyArray<PropertyKey>)
packages/effect/src/internal/errors.ts:4
↓ 17 callersFunctionoptional
( schema: S )
packages/effect/src/unstable/ai/internal/mcpSchema/v2024_11_05.ts:17
↓ 17 callersMethodraw
()
packages/sql/sqlite-do/test/Client.test.ts:17
↓ 17 callersFunctionresolve
()
packages/effect/src/Path.ts:385
↓ 17 callersMethodschema
* Builds a chunk schema from the streaming success schema of an RPC. * * @since 4.0.0
packages/effect/src/unstable/cluster/Reply.ts:222
↓ 16 callersFunctionconsoleWith
(f: (console: Console) => Effect.Effect<A, E, R>)
packages/effect/src/Console.ts:112
↓ 16 callersMethoddigest
* Computes a cryptographic digest for the supplied data.
packages/effect/src/Crypto.ts:98
↓ 16 callersFunctionfailCause
(cause: Cause.Cause<E>)
packages/effect/src/Sink.ts:643
↓ 16 callersFunctionmake
( httpClient: HttpClient.HttpClient, options: { readonly transformClient?: ((client: HttpClient.HttpCl
packages/ai/anthropic/src/Generated.ts:11038
↓ 16 callersMethodpostMessage
(message: ReadonlyArray<unknown>)
packages/sql/sqlite-wasm/test/Client.test.ts:32
↓ 16 callersMethodregister
(options: { readonly maxIdleTime: number readonly servers: Map<EntityId, EntityState> readon
packages/effect/src/unstable/cluster/internal/entityReaper.ts:22
↓ 16 callersFunctionsucceed
(success: A)
packages/effect/src/internal/result.ts:90
↓ 15 callersFunctionhandler
(request: Request, server: BunServer<WebSocketContext>)
packages/platform/bun/src/BunHttpServer.ts:159
↓ 15 callersFunctionmakeSingle
(params: { readonly kind: Kind readonly name: string readonly primitiveType: Primitive.Primitive<A> re
packages/effect/src/unstable/cli/Param.ts:335
↓ 15 callersFunctionmodify
(key: string | RegExp)
packages/effect/src/unstable/http/Headers.ts:394
↓ 15 callersMethodonError
(f: (error: E, result: Failure<A, E>) => B)
packages/effect/src/unstable/reactivity/AsyncResult.ts:859
↓ 15 callersMethodpoll
()
packages/effect/src/PubSub.ts:111
↓ 15 callersMethodrefresh
(this: AtomContext, atom: Atom<A>)
packages/effect/src/unstable/reactivity/Atom.ts:172
↓ 15 callersFunctionschema
(codec: Schema.ConstraintCodec<T, unknown>, path?: string | ConfigProvider.Path)
packages/effect/src/Config.ts:877
↓ 15 callersMethodwhen
( refinement: Predicate<AsyncResult<A, E>>, f: (result: AsyncResult<A, E>) => Option.Option<C> )
packages/effect/src/unstable/reactivity/AsyncResult.ts:822
↓ 15 callersMethodwithPermit
* Runs an effect with the given number of permits and releases the permits * when the effect completes. * * **When to use** * * Use to
packages/effect/src/Semaphore.ts:99
↓ 14 callersFunctionassertMutable
@internal
packages/effect/src/Graph.ts:442
↓ 14 callersMethodcompose
* Composes this optic with another. The result type is the weakest of * the two: Iso + Iso = Iso, Lens + Prism = Optional, etc. * * **Example
packages/effect/src/Optic.ts:480
↓ 14 callersFunctiondiagnostic
(code: string, message: string)
packages/tools/jsdocs/src/Jsdocs.ts:480
↓ 14 callersFunctionfromTransform
( transform: ( upstream: Pull.Pull<InElem, InErr, InDone>, scope: Scope.Scope ) => Effect.Effect<P
packages/effect/src/Channel.ts:283
↓ 14 callersFunctionmake
(node: Node)
packages/effect/src/Optic.ts:1165
↓ 14 callersMethodpeek
()
packages/effect/src/unstable/encoding/Toml.ts:482
↓ 14 callersFunctionreplaceEncoding
(ast: A, encoding: Encoding | undefined)
packages/effect/src/SchemaAST.ts:3344
↓ 13 callersMethodadvance
(count = 1)
packages/effect/src/unstable/encoding/Toml.ts:470
↓ 13 callersFunctionlink
()
packages/effect/src/Schema.ts:6510
↓ 13 callersFunctionmakeResponse
(options: { readonly status: number readonly statusText?: string | undefined readonly headers?: Headers.
packages/effect/src/unstable/http/HttpServerResponse.ts:1336
↓ 13 callersFunctionparseDoc
(text: string)
packages/tools/docgen/src/Parser.ts:103
↓ 13 callersMethodprefix
* Set the schema for the error response of the rpc.
packages/effect/src/unstable/rpc/Rpc.ts:146
↓ 13 callersMethodpublish
(value: A)
packages/effect/src/PubSub.ts:95
↓ 13 callersMethodscheduleTask
(task: () => void, priority: number)
packages/effect/src/Scheduler.ts:58
↓ 13 callersMethodsetTime
* Sets the current clock time to the specified `timestamp`. Any effects that * were scheduled to occur on or before the new time will be run in ord
packages/effect/src/testing/TestClock.ts:105
↓ 13 callersFunctionsome
(predicate: Predicate<In>)
packages/effect/src/Sink.ts:876
↓ 13 callersMethodstat
()
packages/platform/deno/src/DenoFileSystem.ts:199
↓ 12 callersMethodannotate
(annotations: Annotations.Bottom<this["Type"], this["~type.parameters"]>)
packages/effect/src/Schema.ts:185
↓ 12 callersMethodannotateKey
(annotations: Annotations.Key<this["Type"]>)
packages/effect/src/Schema.ts:186
↓ 12 callersMethodassert
(condition: boolean, ...args: ReadonlyArray<any>)
packages/effect/src/Console.ts:26
↓ 12 callersMethodattribute
(key: string, value: unknown)
packages/effect/src/Tracer.ts:384
↓ 12 callersFunctioncallback
( register: ( this: Scheduler.Scheduler, resume: (effect: Effect.Effect<A, E, R>) => void, signa
packages/effect/src/internal/effect.ts:1162
↓ 12 callersFunctiondeclareConstructor
()
packages/effect/src/Schema.ts:489
↓ 12 callersFunctiondeepStrictEqual
(actual: A, expected: A, message?: string, ..._: Array<never>)
packages/vitest/src/utils.ts:41
↓ 12 callersMethoddispose
()
packages/effect/src/unstable/reactivity/AtomRegistry.ts:566
↓ 12 callersFunctionget
(self: Ref<A>)
packages/effect/src/Ref.ts:200
↓ 12 callersFunctionmake
(input: number | bigint)
packages/effect/src/Duration.ts:402
↓ 12 callersFunctionmakeSelect
(options: { readonly from: IndexedDbQuery.From<Table> readonly index?: Index | undefined readonly limitV
packages/platform/browser/src/IndexedDbQueryBuilder.ts:1810
← previousnext →101–200 of 8,651, ranked by callers