orion/purescript-pg
1
0
Fork 0
generated from tpl/purs
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: update node-stream-pipes

Browse Source
This commit is contained in:
orion 2024-05-22 15:49:12 -05:00
parent 7ed85ae22b
commit a56add0ffc
Signed by: orion
GPG Key ID: 6D4165AE4C928719
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
spago.lock
View File

@ -23,7 +23,7 @@ workspace:
- newtype: ">=5.0.0 <6.0.0" - newtype: ">=5.0.0 <6.0.0"
- node-buffer: ">=9.0.0 <10.0.0" - node-buffer: ">=9.0.0 <10.0.0"
- node-event-emitter: ">=3.0.0 <4.0.0" - node-event-emitter: ">=3.0.0 <4.0.0"
- node-stream-pipes: ">=1.2.3 <2.0.0" - node-stream-pipes: ">=1.5.0 <2.0.0"
- node-streams: ">=9.0.0 <10.0.0" - node-streams: ">=9.0.0 <10.0.0"
- nullable: ">=6.0.0 <7.0.0" - nullable: ">=6.0.0 <7.0.0"
- parallel: ">=6.0.0 <7.0.0" - parallel: ">=6.0.0 <7.0.0"
@ -728,8 +728,8 @@ packages:
- unsafe-coerce - unsafe-coerce
node-stream-pipes: node-stream-pipes:
type: registry type: registry
version: 1.2.3 version: 1.5.0
integrity: sha256-lXD3x6+p72uBrRHGHrob2jrrBDakhhZE9O9EYE4aFiE= integrity: sha256-kca0MJ8Pz4tXNpaw7CdysyNAgdbb8yqH1FhOoYbRm5s=
dependencies: dependencies:
- aff - aff
- arrays - arrays

2
spago.yaml
View File

@ -33,7 +33,7 @@ package:
- newtype: ">=5.0.0 <6.0.0" - newtype: ">=5.0.0 <6.0.0"
- node-buffer: ">=9.0.0 <10.0.0" - node-buffer: ">=9.0.0 <10.0.0"
- node-event-emitter: ">=3.0.0 <4.0.0" - node-event-emitter: ">=3.0.0 <4.0.0"
- node-stream-pipes: ">=1.2.3 <2.0.0" - node-stream-pipes: ">=1.5.0 <2.0.0"
- node-streams: ">=9.0.0 <10.0.0" - node-streams: ">=9.0.0 <10.0.0"
- nullable: ">=6.0.0 <7.0.0" - nullable: ">=6.0.0 <7.0.0"
- parallel: ">=6.0.0 <7.0.0" - parallel: ">=6.0.0 <7.0.0"

4
src/Pipes.Postgres.purs
View File

@ -39,7 +39,7 @@ stdin q = do
pure Nothing pure Nothing
releaseOnEOS (Just a) = pure (Just a) releaseOnEOS (Just a) = pure (Just a)
pipe = Pipes.mapM releaseOnEOS >-> fromWritable (O.fromBufferWritable stream) pipe = Pipes.mapM releaseOnEOS >-> fromWritable (O.unsafeFromBufferWritable stream)
err e = do err e = do
liftAff $ void $ Client.exec "rollback" client liftAff $ void $ Client.exec "rollback" client
liftEffect $ Pool.release pool client liftEffect $ Pool.release pool client
@ -62,4 +62,4 @@ stdout q = do
let let
releaseOnEOS Nothing = liftEffect $ Pool.release pool client $> Nothing releaseOnEOS Nothing = liftEffect $ Pool.release pool client $> Nothing
releaseOnEOS (Just a) = pure (Just a) releaseOnEOS (Just a) = pure (Just a)
fromReadable (O.fromBufferReadable stream) >-> Pipes.mapM releaseOnEOS fromReadable (O.unsafeFromBufferReadable stream) >-> Pipes.mapM releaseOnEOS