diff options
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.java | 36 |
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; - } - - - } - } |