module Streamly.Examples.SearchEngineQuery where

import Streamly
import Network.HTTP.Simple

-- Runs three search engine queries in parallel.
searchEngineQuery :: IO ()
searchEngineQuery = do
    putStrLn "Using parallel alternative"
    runStream . parallely $ google <> bing <> duckduckgo

    putStrLn "\nUsing parallel applicative zip"
    runStream . zippingAsync $ (,,) <$> google <*> bing <*> duckduckgo

    where
        get :: IsStream t => String -> t IO ()
        google, bing, duckduckgo :: IsStream t => t IO ()
        get s = serially $ liftIO (httpNoBody (parseRequest_ s) >> putStrLn (show s))
        google     = get "https://www.google.com/search?q=haskell"
        bing       = get "https://www.bing.com/search?q=haskell"
        duckduckgo = get "https://www.duckduckgo.com/?q=haskell"