feat(effects): add optional logging for the take #987

packages/effects/README.md

@@ -293,6 +293,13 @@ const someRequest = reatomRequest<{ data: Data } | { error: string }>()
 const { data } = await take(ctx, someRequest, (ctx, payload, skip) => ('error' in payload ? skip : payload))
 ```
 
+Note that you can increase your debug experience by passing debug name in the four parameter.
+
+```ts
+const a = await take(ctx, someAtom, (ctx, data) => data.a, 'a')
+const b = await take(ctx, bAtom, undefined, 'b')
+```
+
 ### takeNested
 
 Allow you to wait all dependent effects, event if they was called in the nested async effect or by [spawn](#spawn).

packages/effects/src/index.ts

@@ -147,8 +147,14 @@ export const take = <T extends Atom, Res = AtomReturn<T>>(
   ctx: Ctx,
   anAtom: T,
   mapper: Fn<[Ctx, Awaited<AtomReturn<T>>, skip], Res | skip> = (ctx, v: any) => v,
+  name?: string,
 ): Promise<Awaited<Res>> => {
+  name &&= `${ctx.cause.proto.name}.${name}`
+
   const cleanups: Array<Fn> = []
+
+  if (name) action(name)(ctx)
+
   return new Promise<Awaited<Res>>((res: Fn, rej) => {
     cleanups.push(
       onCtxAbort(ctx, rej) ?? noop,
@@ -160,9 +166,13 @@ export const take = <T extends Atom, Res = AtomReturn<T>>(
           if (anAtom.__reatom.isAction) state = state[0].payload
           const value = await state
           const result = mapper(ctx, value, skip)
-          if (result !== skip) res(result)
+          if (result !== skip) {
+            res(result)
+            if (name) action<any>(`${name}.resolve`)(ctx, result)
+          }
         } catch (error) {
           rej(error)
+          if (name) action<any>(`${name}.reject`)(ctx, error)
         }
       }),
     )