MCPcopy Index your code
hub / github.com/Effect-TS/effect / deferredPoll

Function deferredPoll

packages/effect/src/internal/core.ts:2963–2976  ·  view source on GitHub ↗
(
  self: Deferred.Deferred<A, E>
)

Source from the content-addressed store, hash-verified

2961
2962/* @internal */
2963export const deferredPoll = <A, E>(
2964 self: Deferred.Deferred<A, E>
2965): Effect.Effect<Option.Option<Effect.Effect<A, E>>> =>
2966 sync(() => {
2967 const state = MutableRef.get(self.state)
2968 switch (state._tag) {
2969 case DeferredOpCodes.OP_STATE_DONE: {
2970 return Option.some(state.effect)
2971 }
2972 case DeferredOpCodes.OP_STATE_PENDING: {
2973 return Option.none()
2974 }
2975 }
2976 })
2977
2978/* @internal */
2979export const deferredSucceed = dual<

Callers

nothing calls this directly

Calls 2

syncFunction · 0.70
getMethod · 0.65

Tested by

no test coverage detected