aboutsummaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/result/EventStream.java
diff options
context:
space:
mode:
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/result/EventStream.java')
-rw-r--r--container-search/src/main/java/com/yahoo/search/result/EventStream.java36
1 files changed, 1 insertions, 35 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/result/EventStream.java b/container-search/src/main/java/com/yahoo/search/result/EventStream.java
index 8e6f7977d55..b393a91e6d0 100644
--- a/container-search/src/main/java/com/yahoo/search/result/EventStream.java
+++ b/container-search/src/main/java/com/yahoo/search/result/EventStream.java
@@ -41,7 +41,7 @@ public class EventStream extends Hit implements DataList<Data> {
}
public void error(String source, ErrorMessage message) {
- incoming().add(new ErrorEvent(eventCount.incrementAndGet(), source, message));
+ incoming().add(new DefaultErrorHit(source, message));
}
public void markComplete() {
@@ -117,38 +117,4 @@ public class EventStream extends Hit implements DataList<Data> {
}
- public static class ErrorEvent extends Event {
-
- private final String source;
- private final ErrorMessage message;
-
- public ErrorEvent(int eventNumber, String source, ErrorMessage message) {
- super(eventNumber, message.getMessage(), "error");
- this.source = source;
- this.message = message;
- }
-
- public String source() {
- return source;
- }
-
- public int code() {
- return message.getCode();
- }
-
- public String message() {
- return message.getMessage();
- }
-
- @Override
- public Hit asHit() {
- Hit hit = super.asHit();
- hit.setField("source", source);
- hit.setField("code", message.getCode());
- return hit;
- }
-
-
- }
-
}