| Safe Haskell | None |
|---|---|
| Language | GHC2021 |
Ecluse.Pilot.Osv.Stream
Synopsis
- streamOsvUrl :: forall (m :: Type -> Type) i. (MonadResource m, MonadThrow m, KatipContext m) => Telemetry -> String -> ConduitT i ExtractedOsv m ()
- parseOsvStream :: forall (m :: Type -> Type). (MonadResource m, MonadThrow m, KatipContext m) => Telemetry -> ConduitT ByteString ExtractedOsv m ()
Documentation
streamOsvUrl :: forall (m :: Type -> Type) i. (MonadResource m, MonadThrow m, KatipContext m) => Telemetry -> String -> ConduitT i ExtractedOsv m () Source #
Fetch the OSV zip and stream its contents
parseOsvStream :: forall (m :: Type -> Type). (MonadResource m, MonadThrow m, KatipContext m) => Telemetry -> ConduitT ByteString ExtractedOsv m () Source #
Parse the zip stream and emit ExtractedOsv