summaryrefslogtreecommitdiff
path: root/dice-lang/src/bjc/dicelang/scl/StreamEngine.java
diff options
context:
space:
mode:
authorEVE <EVE@EVE-PC>2017-03-13 16:41:45 -0400
committerEVE <EVE@EVE-PC>2017-03-13 16:41:45 -0400
commit01136c6796e21f023713e026674576d8e623462d (patch)
treee77886fe0e0adaf3c0430fba9ce248ef83f74fe4 /dice-lang/src/bjc/dicelang/scl/StreamEngine.java
parent870d769cfc152171d27b2331a7c590d0b307ad48 (diff)
Formatting
Diffstat (limited to 'dice-lang/src/bjc/dicelang/scl/StreamEngine.java')
-rw-r--r--dice-lang/src/bjc/dicelang/scl/StreamEngine.java54
1 files changed, 31 insertions, 23 deletions
diff --git a/dice-lang/src/bjc/dicelang/scl/StreamEngine.java b/dice-lang/src/bjc/dicelang/scl/StreamEngine.java
index 65e566d..9bcad9b 100644
--- a/dice-lang/src/bjc/dicelang/scl/StreamEngine.java
+++ b/dice-lang/src/bjc/dicelang/scl/StreamEngine.java
@@ -32,7 +32,7 @@ public class StreamEngine {
* Our streams.
*/
Tape<IList<String>> streams;
- IList<String> currStream;
+ IList<String> currStream;
/*
* Saved streams
@@ -47,7 +47,8 @@ public class StreamEngine {
/**
* Create a new stream engine.
*
- * @param engine The dice engine we're attached to.
+ * @param engine
+ * The dice engine we're attached to.
*/
public StreamEngine(DiceLangEngine engine) {
eng = engine;
@@ -72,8 +73,10 @@ public class StreamEngine {
/**
* Process a possibly interleaved set of streams from toks into dest.
*
- * @param toks The raw token to read streams from.
- * @param dest The list to write the final stream to.
+ * @param toks
+ * The raw token to read streams from.
+ * @param dest
+ * The list to write the final stream to.
*
* @return Whether or not the streams were successfully processed.
*/
@@ -91,23 +94,23 @@ public class StreamEngine {
/*
* Process each token.
*/
- for(String tk : toks) {
+ for (String tk : toks) {
/*
* Process stream commands.
*/
- if(tk.startsWith("{@S") && !quoteMode) {
- if(tk.equals("{@SQ}")) {
+ if (tk.startsWith("{@S") && !quoteMode) {
+ if (tk.equals("{@SQ}")) {
quoteMode = true;
- } else if(!processCommand(tk)) {
+ } else if (!processCommand(tk)) {
return false;
}
/*
* Command ran correctly, continue
*/
} else {
- if(tk.equals("{@SU}")) {
+ if (tk.equals("{@SU}")) {
quoteMode = false;
- } else if(tk.startsWith("\\") && tk.endsWith("{@SU}")) {
+ } else if (tk.startsWith("\\") && tk.endsWith("{@SU}")) {
currStream.add(tk.substring(1));
} else {
currStream.add(tk);
@@ -115,7 +118,7 @@ public class StreamEngine {
}
}
- for(String tk : currStream) {
+ for (String tk : currStream) {
dest.add(tk);
}
@@ -127,7 +130,7 @@ public class StreamEngine {
}
public boolean rightStream() {
- if(!streams.right()) {
+ if (!streams.right()) {
Errors.inst.printError(EK_STRM_NONEX);
return false;
}
@@ -137,7 +140,7 @@ public class StreamEngine {
}
public boolean leftStream() {
- if(!streams.left()) {
+ if (!streams.left()) {
Errors.inst.printError(EK_STRM_NONEX);
return false;
}
@@ -147,7 +150,7 @@ public class StreamEngine {
}
public boolean deleteStream() {
- if(streams.size() == 1) {
+ if (streams.size() == 1) {
Errors.inst.printError(EK_STRM_LAST);
return false;
} else {
@@ -159,7 +162,7 @@ public class StreamEngine {
}
public boolean mergeStream() {
- if(streams.size() == 1) {
+ if (streams.size() == 1) {
Errors.inst.printError(EK_STRM_LAST);
return false;
} else {
@@ -174,7 +177,7 @@ public class StreamEngine {
private boolean processCommand(String tk) {
char[] comms = null;
- if(tk.length() > 5) {
+ if (tk.length() > 5) {
comms = tk.substring(3, tk.length() - 1).toCharArray();
} else {
comms = new char[1];
@@ -183,30 +186,35 @@ public class StreamEngine {
boolean succ;
- for(char comm : comms) {
- switch(comm) {
+ for (char comm : comms) {
+ switch (comm) {
case '+':
newStream();
break;
case '>':
succ = rightStream();
- if(!succ) return false;
+ if (!succ)
+ return false;
break;
case '<':
succ = leftStream();
- if(!succ) return false;
+ if (!succ)
+ return false;
break;
case '-':
succ = deleteStream();
- if(!succ) return false;
+ if (!succ)
+ return false;
break;
case 'M':
succ = mergeStream();
- if(!succ) return false;
+ if (!succ)
+ return false;
break;
case 'L':
succ = scleng.runProgram(currStream.toArray(new String[0]));
- if(!succ) return false;
+ if (!succ)
+ return false;
break;
default:
Errors.inst.printError(EK_STRM_INVCOM, tk);