purescript-redis-client's scanStream implementation

Scan.js

"use strict";
const Redis = require('ioredis')

exports.scanStreamImpl = conn => options => (onError, onSuccess) => { 
    const redis = new Redis(conn.options)
    var stream = redis.scanStream(options) 
    
    stream.on("data", resultKeys => {
        // `resultKeys` is an array of strings representing key names.
        // Note that resultKeys may contain 0 keys, and that it will sometimes
        // contain duplicates due to SCAN's implementation in Redis.
        // woody: Should I check for duplicates here or leave it to end user??
        onSuccess(resultKeys)
    });

    stream.on("error", err => {
        onError(err)
    })

    stream.on("end", () => {
        redis.disconnect()
    })

    return function (cancelError, cancelerError, cancelerSuccess) {
        redis.disconnect()
        cancelerSuccess()
    }
}

Scan.purs

module Infra.Resources.Database.Redis.Scan (ScanStreamOptions, scanStream) where

import Prelude
import Data.ByteString (ByteString)
import Database.Redis as Redis
import Effect.Aff (Aff)
import Effect.Aff.Compat (EffectFnAff, fromEffectFnAff)
import Prim.Row (class Union)

foreign import scanStreamImpl :: forall opts. Redis.Connection -> Record opts -> EffectFnAff (Array ByteString)

type ScanStreamOptions 
    = ( count :: Int 
      , match :: String 
      )

scanStream :: forall options t. 
    Union options t ScanStreamOptions 
    => Redis.Connection 
    -> Record options 
    -> Aff (Array ByteString)
scanStream redis options = fromEffectFnAff $ scanStreamImpl redis options