event和effect的使用问题 about remesh HOT 4 CLOSED

import { Observable, takeUntil, switchMap } from 'rxjs'

type DownloadState = {
    type: 'progress'
    progress: number
} | {
    type: 'error'
    error: string
} | {
    type: 'success'
    file: Blob
}

const download = (url: string) => {
    return new Observable<DownloadState>(subscriber => {
        const downloadId = downloader.startDownload(url, {
            onProgress: (progress) => {
                subscriber.next({ type: 'progress', progress })
            },
            onFinish: (file: Blob) => {
                subscriber.next({ type: 'success', file })
                subscriber.complete()
            },
            onFailed: (message: string) => {
                subscriber.next({ type: 'error', error: message })
                subscriber.complete()
            },
        })

        const unsubscribe = () => {
            downloader.cancelDownload(downloadId)
        }

        return unsubscribe
    })
}


domain.effect({
    name: 'DownloadEffect',
    impl: ({ fromEvent }) => {
        return fromEvent(DownloadStartedEvent).pipe(
            switchMap(event => {
                // cancel download if user cancels it
                return download(event.url).pipe(
                    takeUntil(fromEvent(DownloadCancelledEvent)),
                )
            }),
            map(state => {
                switch (state.type) {
                    case 'progress':
                        return DownloadProgressEvent(state.progress)
                    case 'error':
                        return DownloadFailedEvent(state.error)
                    case 'success':
                        return DownloadFinishedEvent(state.file)
                }
            })
        )
    }
})

domain.effect({
    name: 'DownloadEffect',
    impl: ({ fromEvent }) => {
        return fromEvent(DownloadStartedEvent).pipe(
            // for each download event, create a stream of progress events
            // merge them together instead of switching
            mergeMap(event => {
                // create a stream of cancel events for this download
                const cancel$ = fromEvent(DownloadCancelledEvent).pipe(
                    filter(cancelledEvent => cancelledEvent.url === event.url)
                )
                // cancel download if user cancels it
                return download(event.url).pipe(takeUntil(cancel$))
            }),
            map(state => {
                switch (state.type) {
                    case 'progress':
                        return DownloadProgressEvent(state)
                    case 'error':
                        return DownloadFailedEvent(state)
                    case 'success':
                        return DownloadFinishedEvent(state)
                }
            })
        )
    }
})