You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
asConduit appears to create a conduit which consumes the entire sequence; then when done, binds cons steps into it's Done constructor.
After the conduit is completely consumed, the stream function is applied. To demonstrate, I believe this code is effectively equivalent (this also shows that the stream consumed contains precisely 0 Effect constructors).
overList:: (Monadm) => ([i] -> [o]) ->ConduitMiom()
overList f = join .fmap (Conduit.sourceList . f) $ go
where
go =do mo <- await
case mo ofNothing->return[]Just o -> (o :) <$> go
I'm not convinced that this type signature is able to be implemented satisfactorily. Although one should be able to with a stream Stream (Of i) (ConduitT i o m) ().
The text was updated successfully, but these errors were encountered:
asConduit
appears to create a conduit which consumes the entire sequence; then when done, binds cons steps into it'sDone
constructor.After the conduit is completely consumed, the stream function is applied. To demonstrate, I believe this code is effectively equivalent (this also shows that the stream consumed contains precisely 0
Effect
constructors).I'm not convinced that this type signature is able to be implemented satisfactorily. Although one should be able to with a stream
Stream (Of i) (ConduitT i o m) ()
.The text was updated successfully, but these errors were encountered: