Sha256: 67f2c83be54ec71b0641ad5527aa2c0c9bcc25656ca6169644555a80d1c12965

Contents?: true

Size: 937 Bytes

Versions: 4

Compression:

Stored size: 937 Bytes

Contents

require 'minitest_helper'

describe Asynchronic::QueueEngine::Synchronic do

  before do
    Asynchronic.configure do |config|
      config.queue_engine = Asynchronic::QueueEngine::Synchronic.new
    end
  end

  after do
    Asynchronic.environment.data_store.clear
  end

  it 'Original job' do
    pid = BasicJob.enqueue input: 1
    process = Asynchronic[pid]
    process.result.must_equal 2
  end

  it 'Stub job' do
    Asynchronic.queue_engine.stub BasicJob do |process|
      process.params[:input] + 19
    end

    pid = BasicJob.enqueue input: 1
    process = Asynchronic[pid]
    process.result.must_equal 20
  end

  it 'Graph job' do
    pid = GraphJob.enqueue input: 100
    process = Asynchronic[pid]
    process.must_be_completed
    process.result.must_equal '10%' => 20, '20%' => 40
  end

  it 'Active connections' do
    Asynchronic.queue_engine.active_connections.must_equal [Asynchronic.connection_name]
  end

end

Version data entries

4 entries across 4 versions & 1 rubygems

Version Path
asynchronic-4.0.3 spec/queue_engine/synchronic_spec.rb
asynchronic-4.0.2 spec/queue_engine/synchronic_spec.rb
asynchronic-4.0.1 spec/queue_engine/synchronic_spec.rb
asynchronic-4.0.0 spec/queue_engine/synchronic_spec.rb