Fluxite

Fluxite is a reactivity/reactive streams-ish library for Crystal. The main feature is that it uses a message queue instead of recursion allowing (potentially) unbounded feedback.

world = Fluxite::Port(Symbol).new
world.select(:tick).map { :tock }.into(world)
world.select(:tock).map { :tick }.into(world)
world.each { |sym| p! sym }

Fluxite.pass(world, :tick)

# STDOUT:
#   sym # => :tick
#   sym # => :tock
#   sym # => :tick
#   sym # => :tock
#   sym # => :tick
#   sym # => :tock
# ... forever

Also message propagation is much more intuitive than in more naive reactive streams implementations, and is more like circuits (Fluxite is breadth-first vs. depth-first naive reactive systems). That is, progress is made across the entire level of the tree before descending deeper.

Installation

1. Add the dependency to your shard.yml:

   dependencies:
     fluxite:
       github: homonoidian/fluxite
   

2. Run shards install

Usage

require "fluxite"

TODO: Write usage instructions here

Development

TODO: Write development instructions here

Contributing

1. Fork it (https://github.com/homonoidian/fluxite/fork)
2. Create your feature branch (git checkout -b my-new-feature)
3. Commit your changes (git commit -am 'Add some feature')
4. Push to the branch (git push origin my-new-feature)
5. Create a new Pull Request

Contributors

• Alexey Yurchenko - creator and maintainer