( self: Deferred.Deferred<A, E> )
| 2961 | |
| 2962 | /* @internal */ |
| 2963 | export 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 */ |
| 2979 | export const deferredSucceed = dual< |