async_await

async/await for Crystal

Installation

Add this to your application's shard.yml:

dependencies:
  async_await:
    github: firejox/crystal-async_await

Usage

require "async_await"

class Foo
  getter ch = AAChannel(String).new

  async def bar
    await Task.delay(Time::Span.new(0, 0, 1))
    await ch.receive  # => "Hello"
    await ch.send "Crystal!"
  end
end

foo = Foo.new

async_spawn do
  foo.bar
end

foo.ch.send_with_csp "Hello"
foo.ch.receive_with_csp # => "Crystal!"

another way for concurrent

Roadmap

• Async IO
• Thread Pool Support
• Cancellation for Task
• Test more

Contributing

1. Fork it ( https://github.com/firejox/crystal-async_await/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

• firejox firejox - creator, maintainer