summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorKevin Smith <git@kismith.co.uk>2012-10-18 16:27:38 (GMT)
committerKevin Smith <git@kismith.co.uk>2012-10-18 16:27:38 (GMT)
commite1ab207943693a5d7c31d103f538f6c859c436ff (patch)
treedbc5740fdb7cb17d304e08993c4d2b201a95f12e /src/com/isode/stroke/streamstack
parentb929d80743dca78406f0fb338175c90590a4ed67 (diff)
downloadstroke-e1ab207943693a5d7c31d103f538f6c859c436ff.zip
stroke-e1ab207943693a5d7c31d103f538f6c859c436ff.tar.bz2
And more cleanup
Change-Id: I49cf4cba01452b291655dfccdc134180270c1ff3
Diffstat (limited to 'src/com/isode/stroke/streamstack')
-rw-r--r--src/com/isode/stroke/streamstack/XMPPLayer.java27
1 files changed, 13 insertions, 14 deletions
diff --git a/src/com/isode/stroke/streamstack/XMPPLayer.java b/src/com/isode/stroke/streamstack/XMPPLayer.java
index 8163998..34c25b5 100644
--- a/src/com/isode/stroke/streamstack/XMPPLayer.java
+++ b/src/com/isode/stroke/streamstack/XMPPLayer.java
@@ -29,7 +29,20 @@ import com.isode.stroke.signals.Signal1;
* XML parsing being multi-threaded here.
*/
public class XMPPLayer implements HighLayer, XMPPParserClient {
+ public final Signal1<ProtocolHeader> onStreamStart = new Signal1<ProtocolHeader>();
+ public final Signal1<Element> onElement = new Signal1<Element>();
+ public final Signal1<ByteArray> onWriteData = new Signal1<ByteArray>();
+ public final Signal1<ByteArray> onDataRead = new Signal1<ByteArray>();
+ public final Signal onError = new Signal();
+ private PayloadParserFactoryCollection payloadParserFactories_;
+ private XMPPParser xmppParser_;
+ private PayloadSerializerCollection payloadSerializers_;
+ private XMPPSerializer xmppSerializer_;
+ private boolean resetParserAfterParse_;
+ private boolean inParser_;
+
+
public XMPPLayer(
PayloadParserFactoryCollection payloadParserFactories,
PayloadSerializerCollection payloadSerializers,
@@ -80,12 +93,6 @@ public class XMPPLayer implements HighLayer, XMPPParserClient {
writeDataToChildLayer(data);
}
- public final Signal1<ProtocolHeader> onStreamStart = new Signal1<ProtocolHeader>();
- public final Signal1<Element> onElement = new Signal1<Element>();
- public final Signal1<ByteArray> onWriteData = new Signal1<ByteArray>();
- public final Signal1<ByteArray> onDataRead = new Signal1<ByteArray>();
- public final Signal onError = new Signal();
-
public void handleStreamStart(ProtocolHeader header) {
onStreamStart.emit(header);
}
@@ -102,14 +109,6 @@ public class XMPPLayer implements HighLayer, XMPPParserClient {
resetParserAfterParse_ = false;
}
- private PayloadParserFactoryCollection payloadParserFactories_;
- private XMPPParser xmppParser_;
- private PayloadSerializerCollection payloadSerializers_;
- private XMPPSerializer xmppSerializer_;
- private boolean resetParserAfterParse_;
- private boolean inParser_;
- private EventLoop eventLoop_;
-
/* Multiple-inheritance workarounds */
private StreamLayer fakeStreamLayer_ = new StreamLayer() {