ipfs-product-image.effects.ts

uploadImage$ = createEffect(
    () =>
      this.actions$.pipe(
        ofType(IpfsImageActions.uploadImage),
        map(action => action.file),
        exhaustMap((file) => {

          return this.ipfsSrv.addFile(file).pipe(
            tap(ipfsHash => console.log(`IPFS file hash: ${ipfsHash}`)),
            map(ipfsHash => IpfsImageActions.uploadImageSuccess({ ipfsHash })),
            catchError((err: Error) =>
              of(this.handleError(err), IpfsImageActions.uploadImageFail())
            )
          );
        })

      ));