@@ -891,7 +891,7 @@ indexedR n = fromStreamD . D.indexedR n . toStreamD
892{-# INLINE timestampWith #-}
892{-# INLINE timestampWith #-}
893timestampWith :: (MonadIO m)
893timestampWith :: (MonadIO m)
894− => Double -> Stream m a -> Stream m(AbsTime, a)
894+ => Double -> Stream m a -> Stream m (AbsTime, a)
895timestampWith g stream = zipWith (flip (,)) stream (absTimesWith g)
895timestampWith g stream = zipWith (flip (,)) stream (absTimesWith g)
897-- TBD: check performance vs a custom implementation without using zipWith.
897-- TBD: check performance vs a custom implementation without using zipWith.
@@ -900,7 +900,7 @@ timestampWith g stream = zipWith (flip (,)) stream (absTimesWith g)
901{-# INLINE timestamped #-}
901{-# INLINE timestamped #-}
902timestamped :: (MonadIO m)
902timestamped :: (MonadIO m)
903− => Stream m a -> Stream m(AbsTime, a)
903+ => Stream m a -> Stream m (AbsTime, a)
904timestamped = timestampWith 0.01
904timestamped = timestampWith 0.01
906-- | Pair each element in a stream with relative times starting from 0, using a
906-- | Pair each element in a stream with relative times starting from 0, using a
@@ -914,7 +914,7 @@ timestamped = timestampWith 0.01
915{-# INLINE timeIndexWith #-}
915{-# INLINE timeIndexWith #-}
916timeIndexWith :: (MonadIO m)
916timeIndexWith :: (MonadIO m)
917− => Double -> Stream m a -> Stream m(RelTime64, a)
917+ => Double -> Stream m a -> Stream m (RelTime64, a)
918timeIndexWith g stream = zipWith (flip (,)) stream (relTimesWith g)
918timeIndexWith g stream = zipWith (flip (,)) stream (relTimesWith g)
920-- | Pair each element in a stream with relative times starting from 0, using a
920-- | Pair each element in a stream with relative times starting from 0, using a
@@ -928,7 +928,7 @@ timeIndexWith g stream = zipWith (flip (,)) stream (relTimesWith g)
929{-# INLINE timeIndexed #-}
929{-# INLINE timeIndexed #-}
930timeIndexed :: (MonadIO m)
930timeIndexed :: (MonadIO m)
931− => Stream m a -> Stream m(RelTime64, a)
931+ => Stream m a -> Stream m (RelTime64, a)
932timeIndexed = timeIndexWith 0.01
932timeIndexed = timeIndexWith 0.01
934------------------------------------------------------------------------------
934------------------------------------------------------------------------------