@@ -891,7 +891,7 @@ indexedR n = fromStreamD . D.indexedR n . toStreamD
891891--
892892{-# INLINE timestampWith #-}
893893timestampWith :: (MonadIO m )
894- => Double -> Stream m a -> Stream m (AbsTime , a )
894+ => Double -> Stream m a -> Stream m (AbsTime , a )
895895timestampWith g stream = zipWith (flip (,)) stream (absTimesWith g)
896896
897897-- TBD: check performance vs a custom implementation without using zipWith.
@@ -900,7 +900,7 @@ timestampWith g stream = zipWith (flip (,)) stream (absTimesWith g)
900900--
901901{-# INLINE timestamped #-}
902902timestamped :: (MonadIO m )
903- => Stream m a -> Stream m (AbsTime , a )
903+ => Stream m a -> Stream m (AbsTime , a )
904904timestamped = timestampWith 0.01
905905
906906-- | Pair each element in a stream with relative times starting from 0, using a
@@ -914,7 +914,7 @@ timestamped = timestampWith 0.01
914914--
915915{-# INLINE timeIndexWith #-}
916916timeIndexWith :: (MonadIO m )
917- => Double -> Stream m a -> Stream m (RelTime64 , a )
917+ => Double -> Stream m a -> Stream m (RelTime64 , a )
918918timeIndexWith g stream = zipWith (flip (,)) stream (relTimesWith g)
919919
920920-- | 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)
928928--
929929{-# INLINE timeIndexed #-}
930930timeIndexed :: (MonadIO m )
931- => Stream m a -> Stream m (RelTime64 , a )
931+ => Stream m a -> Stream m (RelTime64 , a )
932932timeIndexed = timeIndexWith 0.01
933933
934934------------------------------------------------------------------------------
0 commit comments