thx.stream

Stream library for Haxe.
https://github.com/fponticelli/thx.stream

To install, run:

haxelib install thx.stream 0.6.1 

See using Haxelib in Haxelib documentation for more information.

README.md

thx.stream

Build Status

Streaming library

install

From the command line just type:

haxelib install thx.stream

To use the dev version do:

haxelib git thx.core https://github.com/fponticelli/thx.stream.git

TODO

  • endWhen(other: Stream): Stream (from xstream): Uses another stream to determine when to complete the current stream. When the given other stream emits an event or completes, the output stream will complete. Before that happens, the output stream will behaves like the input stream.
  • recover(other: Stream): Stream: if the stream ends with an error it is replaced by other
  • compose (from xstream): Passes the input stream to a custom operator, to produce an output stream. compose is a handy way of using an existing function in a chained style. Instead of writing outStream = f(inStream) you can write outStream = inStream.compose(f).
  • remember() (from xstream): Returns an output stream that behaves like the input stream, but also remembers the most recent event that happens on the input stream, so that a newly added listener will immediately receive that memorised event.
  • imitate: https://github.com/staltz/xstream#imitate
  • query methods any all contains memberOf
Contributors
fponticelli
Version
0.6.1
Published
1 year ago
License
MIT

All libraries are free

Every month, more than thousand developers use haxelib to find, share, and reuse code — and assemble it in powerful new ways. Enjoy Haxe; It is great!

Explore Haxe

Haxe Manual

Haxe Code Cookbook

Haxe API documentation

You can try Haxe in the browser! try.haxe.org

Join us on Github!

Haxe is being developed on GitHub. Feel free to contribute or report issues to our projects.

Haxe on Github