Data.Conduit.Algorithms.Storable

Read/write Storable vectors

Documentation

writeStorableV :: forall m a. (MonadIO m, Monad m, Storable a) => ConduitT (Vector a) ByteString m ()

write a Storable vector

This uses the same format as in-memory

See readStorableV

readStorableV :: forall m a. (MonadIO m, Storable a) => Int -> ConduitM ByteString (Vector a) m ()

read a Storable vector

This expects the same format as the in-memory vector.

This will break up the incoming data into vectors of the given size. The last vector may be smaller if there is not enough data. Any unconsumed Bytes will be leftover for the next conduit in the pipeline.

See writeStorableV