Add proctypes tests

test/fakeproc.jl

@@ -0,0 +1,19 @@
+@everywhere begin
+
+using Dagger
+
+struct FakeProc <: Dagger.Processor end
+
+Dagger.iscompatible(proc::FakeProc, opts, x::Integer) = true
+Dagger.iscompatible(proc::FakeProc, opts, x::String) = true
+Dagger.move(ctx, from_proc::OSProc, to_proc::FakeProc, x::Integer) = x
+Dagger.move(ctx, from_proc::FakeProc, to_proc::OSProc, x::Integer) = x
+Dagger.move(ctx, from_proc::FakeProc, to_proc::OSProc, x::String) = parse(Int,x)
+Dagger.execute!(proc::FakeProc, func, arg::Integer) = func(arg)
+Dagger.execute!(proc::FakeProc, func, args...) = "42" * func(string.(args)...)
+
+push!(Dagger.PROCESSOR_CALLBACKS, proc -> begin
+    push!(proc.children, FakeProc())
+end)
+
+end

test/runtests.jl

@@ -4,6 +4,8 @@ addprocs(2)
 using Test
 using Dagger
 
+include("fakeproc.jl")
+
 include("domain.jl")
 include("array.jl")
 include("scheduler.jl")

test/scheduler.jl

@@ -48,4 +48,17 @@ end
             @test collect(Context(), a) == 1
         end
     end
+
+    @testset "Thunk options: proctypes" begin
+        @test Dagger.iscompatible(FakeProc(), nothing, 1) == true
+        @test Dagger.iscompatible(FakeProc(), nothing, "1") == true
+        @test Dagger.iscompatible(FakeProc(), nothing, 1.0) == false
+
+        as = [delayed(identity)(i) for i in 1:10]
+        opts = Dagger.Sch.ThunkOptions(;proctypes=[FakeProc])
+        b = delayed(*; options=opts)(as...)
+
+        @test collect(b) == 4212345678910
+    end
+
 end