Language.Java.Streaming

Expose Java iterators as streams from the streaming package.

Documentation

reifyStreamWithBatching

Arguments

:: forall a. BatchReify a

=> Int32

The batch size

-> J ('Iface "java.util.Iterator" <> '[Interp a])

-> IO (Stream (Of a) IO ())

Reifies streams from iterators in batches of the given size.

reflectStreamWithBatching

Arguments

:: forall a. BatchReflect a

=> Int

The batch size

-> Stream (Of a) IO ()

-> IO (J ('Iface "java.util.Iterator" <> '[Interp a]))

Reflects streams to iterators in batches of the given size.

Orphan instances

(Typeable (Dict (Reflect (Stream (Of a) IO ()))), Typeable (Dict (BatchReflect a)), Static (BatchReflect a)) => Static (Reflect (Stream (Of a) IO ()))

Methods

closureDict :: Closure (Dict (Reflect (Stream (Of a) IO ())))

(Typeable (Dict (Reify (Stream (Of a) IO ()))), Typeable (Dict (BatchReify a)), Static (BatchReify a)) => Static (Reify (Stream (Of a) IO ()))

Methods

closureDict :: Closure (Dict (Reify (Stream (Of a) IO ())))

Interpretation (Stream (Of a) m r :: Type)

Associated Types

type Interp (Stream (Of a) m r) :: JType

Typeable (Dict (Interpretation (Stream (Of a) m r))) => Static (Interpretation (Stream (Of a) m r))

Methods

closureDict :: Closure (Dict (Interpretation (Stream (Of a) m r)))

BatchReflect a => Reflect (Stream (Of a) IO ())

Methods

reflect :: Stream (Of a) IO () -> IO (J (Interp (Stream (Of a) IO ())))

BatchReify a => Reify (Stream (Of a) IO ())

Methods

reify :: J (Interp (Stream (Of a) IO ())) -> IO (Stream (Of a) IO ())