error message

error

Error in line 1: while requiring "./channel_spec.cr"

in channel_spec.cr:122: instantiating 'AsyncAwait::Channel(T):Class#select_with_csp()'

    AAChannel.select_with_csp do |x|
              ^~~~~~~~~~~~~~~

in /home/firejox/develop/async_await/src/async_await/channel.cr:290: instantiating 'AsyncAwait::Channel(T):Class#select()'

      self.select do |action|
           ^~~~~~

in /home/firejox/develop/async_await/src/async_await/channel.cr:290: instantiating 'AsyncAwait::Channel(T):Class#select()'

      self.select do |action|
           ^~~~~~

in channel_spec.cr:122: instantiating 'AsyncAwait::Channel(T):Class#select_with_csp()'

    AAChannel.select_with_csp do |x|
              ^~~~~~~~~~~~~~~

in channel_spec.cr:123: instantiating 'AsyncAwait::Channel::Selector#add_receive_action(AsyncAwait::Channel(Int32))'

      x.add_receive_action ch1 do |val|
        ^~~~~~~~~~~~~~~~~~

in /home/firejox/develop/async_await/src/async_await/channel.cr:354: instantiating 'AsyncAwait::Channel(Int32)#receive(AsyncAwait::Channel::SelectCompletionSource(Int32))'

        ch.receive scs
           ^~~~~~~

in /home/firejox/develop/async_await/src/async_await/channel.cr:144: instantiating 'receive_impl(AsyncAwait::Channel::SelectCompletionSource(Int32))'

      receive_impl(tcs) do
      ^~~~~~~~~~~~

in /home/firejox/develop/async_await/src/async_await/channel.cr:158: instantiating 'Thread::Mutex#synchronize()'

      @mutex.synchronize do |mtx|
             ^~~~~~~~~~~

in /home/firejox/develop/async_await/src/async_await/channel.cr:158: instantiating 'Thread::Mutex#synchronize()'

      @mutex.synchronize do |mtx|
             ^~~~~~~~~~~

in /home/firejox/develop/async_await/src/async_await/channel.cr:159: instantiating 'loop()'

        loop do
        ^~~~

in /home/firejox/develop/async_await/src/async_await/channel.cr:159: instantiating 'loop()'

        loop do
        ^~~~

in /home/firejox/develop/async_await/src/async_await/channel.cr:185: instantiating 'Deque(AsyncAwait::TaskCompletionSource(Int32))#push(AsyncAwait::Channel::SelectCompletionSource(Int32))'

            @queue.push tcs
                   ^~~~

in /home/firejox/develop/crystal/src/deque.cr:404: instantiating 'Pointer(AsyncAwait::TaskCompletionSource(Int32))#[]=(Int32, AsyncAwait::Channel::SelectCompletionSource(Int32))'

    @buffer[index] = value
           ^

in /home/firejox/develop/crystal/src/pointer.cr:127: instantiating 'Pointer(AsyncAwait::TaskCompletionSource(Int32))#value=(AsyncAwait::Channel::SelectCompletionSource(Int32))'

    (self + offset).value = value
                    ^~~~~

in /home/firejox/develop/async_await/src/async_await/channel.cr:56: instantiating 'AsyncAwait::TaskCompletionSource(Int32)+#try_set_value?(Int32)'

            next unless tcs.try_set_value? value
                            ^~~~~~~~~~~~~~

in /home/firejox/develop/async_await/src/async_await/task_completion_source.cr:29: instantiating 'loop()'

      loop do
      ^~~~

in /home/firejox/develop/async_await/src/async_await/task_completion_source.cr:29: instantiating 'loop()'

      loop do
      ^~~~

in /home/firejox/develop/async_await/src/async_await/task_completion_source.cr:31: protected method 'value=' called for AsyncAwait::Task(T)

          @task.value = value
                ^~~~~