aboutsummaryrefslogtreecommitdiff
path: root/juick-server/src/main/java/com/juick/server/xmpp/router/Stream.java
diff options
context:
space:
mode:
Diffstat (limited to 'juick-server/src/main/java/com/juick/server/xmpp/router/Stream.java')
-rw-r--r--juick-server/src/main/java/com/juick/server/xmpp/router/Stream.java20
1 files changed, 18 insertions, 2 deletions
diff --git a/juick-server/src/main/java/com/juick/server/xmpp/router/Stream.java b/juick-server/src/main/java/com/juick/server/xmpp/router/Stream.java
index 7532443c..4319bee7 100644
--- a/juick-server/src/main/java/com/juick/server/xmpp/router/Stream.java
+++ b/juick-server/src/main/java/com/juick/server/xmpp/router/Stream.java
@@ -45,7 +45,7 @@ public abstract class Stream {
this.loggedIn = loggedIn;
}
- Jid from;
+ public Jid from;
public Jid to;
private InputStream is;
private OutputStream os;
@@ -69,7 +69,7 @@ public abstract class Stream {
streamId = UUID.randomUUID().toString();
}
- void restartStream() throws XmlPullParserException {
+ public void restartStream() throws XmlPullParserException {
parser = factory.newPullParser();
parser.setInput(new InputStreamReader(is, StandardCharsets.UTF_8));
parser.setFeature(XmlPullParser.FEATURE_PROCESS_NAMESPACES, true);
@@ -181,4 +181,20 @@ public abstract class Stream {
public void setUpdated() {
this.updated = Instant.now();
}
+
+ public InputStream getInputStream() {
+ return is;
+ }
+
+ public void setInputStream(InputStream is) {
+ this.is = is;
+ }
+
+ public OutputStream getOutputStream() {
+ return os;
+ }
+
+ public void setOutputStream(OutputStream os) {
+ this.os = os;
+ }
}