Stream<Res> Uses

Connectionfetch_all_async. : function(self : Connection , query : string , params : { any } , chunk_count : integer) : Stream<any>

Type doc:

Returned from connection:fetch_all_async(). It allows you to do other things while the query is running in a background thread.

Methods:



                        iter: function(self : Stream<Res>): ((function(Stream<Res>) : Res ) , (Stream<Res>))

Constructs a blocking iterator that will loop over all the items.



                        try_next: function(self : Stream<Res>): ((boolean ) , (Res))

returns the next item if it is available or nill if not.

Does NOT block the main thread.



                        next: function(self : Stream<Res>) : Res

Waits until the next item is available and then returns it.

DOES block the main thread



                        loop_all: function<Out>(self : Stream<Res> , function(Res) : Out) : ({ Out })



                        help: function(string) : string

Inherits:


userdata