ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-01-07 13:38:47 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

move Continuations and Coroutines tests to top-level test directory

Browse Source
This commit is contained in:
Joel Dice 2009-05-18 09:17:49 -06:00
parent e35047b056
commit db91c27441
2 changed files with 42 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
test/extra/Continuations.java → test/Continuations.java
View File

@ -1,5 +1,3 @@
package extra;
import static avian.Continuations.callWithCurrentContinuation;
import avian.CallbackReceiver;

70
test/extra/Coroutines.java → test/Coroutines.java
View File

@ -1,5 +1,3 @@
package extra;
import static avian.Continuations.callWithCurrentContinuation;
import avian.CallbackReceiver;
@ -11,15 +9,28 @@ public class Coroutines {
}
private static void produce(Consumer<Character> consumer) throws Exception {
System.out.println("produce \"a\"");
consumer.consume('a');
System.out.println("produce \"b\"");
consumer.consume('b');
System.out.println("produce \"c\"");
consumer.consume('c');
}
private static void consume(Producer<Character> producer) throws Exception {
expect(producer.produce() == 'a');
expect(producer.produce() == 'b');
expect(producer.produce() == 'c');
char v = producer.produce();
System.out.println("consume \"" + v + "\"");
expect(v == 'a');
v = producer.produce();
System.out.println("consume \"" + v + "\"");
expect(v == 'b');
v = producer.produce();
System.out.println("consume \"" + v + "\"");
expect(v == 'c');
}
public static void main(String[] args) throws Exception {
@ -28,30 +39,10 @@ public class Coroutines {
final Consumer<Character> consumer = new Consumer<Character>() {
public void consume(final Character c) throws Exception {
callWithCurrentContinuation(new CallbackReceiver() {
public Object receive(Callback continuation) {
state.produceNext = continuation;
public Object receive(Callback continuation) {
state.produceNext = continuation;
state.consumeNext.handleResult(c);
throw new AssertionError();
}
});
}
};
final Producer<Character> producer = new Producer<Character>() {
public Character produce() throws Exception {
return callWithCurrentContinuation(new CallbackReceiver<Character>() {
public Character receive(Callback<Character> continuation)
throws Exception
{
state.consumeNext = continuation;
if (state.produceNext == null) {
Coroutines.produce(consumer);
} else {
state.produceNext.handleResult(null);
}
state.consumeNext.handleResult(c);
throw new AssertionError();
}
@ -59,6 +50,29 @@ public class Coroutines {
}
};
final Producer<Character> producer = new Producer<Character>() {
final CallbackReceiver<Character> receiver
= new CallbackReceiver<Character>() {
public Character receive(Callback<Character> continuation)
throws Exception
{
state.consumeNext = continuation;
if (state.produceNext == null) {
Coroutines.produce(consumer);
} else {
state.produceNext.handleResult(null);
}
throw new AssertionError();
}
};
public Character produce() throws Exception {
return callWithCurrentContinuation(receiver);
}
};
consume(producer);
}