aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/io/trygvis/esper/testing/nexus
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/io/trygvis/esper/testing/nexus')
-rw-r--r--src/main/java/io/trygvis/esper/testing/nexus/NexusClient.java7
1 files changed, 5 insertions, 2 deletions
diff --git a/src/main/java/io/trygvis/esper/testing/nexus/NexusClient.java b/src/main/java/io/trygvis/esper/testing/nexus/NexusClient.java
index 9900bfc..fe0db33 100644
--- a/src/main/java/io/trygvis/esper/testing/nexus/NexusClient.java
+++ b/src/main/java/io/trygvis/esper/testing/nexus/NexusClient.java
@@ -1,5 +1,6 @@
package io.trygvis.esper.testing.nexus;
+import fj.*;
import fj.data.*;
import static fj.data.Option.*;
import static io.trygvis.esper.testing.nexus.SearchNGResponseParser.*;
@@ -45,13 +46,15 @@ public class NexusClient {
System.out.println("args = " + args);
URI uri = URI.create(nexusUrl.toASCIIString() + "/service/local/feeds/" + timeline + args);
- Option<Document> d = xmlHttpClient.fetch(uri);
+ Option<P2<Document,byte[]>> d = xmlHttpClient.fetch(uri);
if (d.isNone()) {
return new NexusFeed(Collections.<HasNexusEvent>emptyList());
}
- Document document = d.some();
+ Document document = d.some()._1();
+
+ // TODO: store data
return NexusFeedParser.parseDocument(document);
}