diff options
Diffstat (limited to 'vespa-feed-client')
-rw-r--r-- | vespa-feed-client/src/main/java/ai/vespa/feed/client/JsonStreamFeeder.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/JsonStreamFeeder.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/JsonStreamFeeder.java index 74965270fb9..72eb96c2356 100644 --- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/JsonStreamFeeder.java +++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/JsonStreamFeeder.java @@ -6,6 +6,7 @@ import com.fasterxml.jackson.core.JsonFactory; import com.fasterxml.jackson.core.JsonParser; import com.fasterxml.jackson.core.JsonToken; +import java.io.Closeable; import java.io.IOException; import java.io.InputStream; import java.io.InterruptedIOException; @@ -28,7 +29,7 @@ import static java.util.Objects.requireNonNull; /** * @author jonmv */ -public class JsonStreamFeeder { +public class JsonStreamFeeder implements Closeable { private final FeedClient client; private final OperationParameters protoParameters; @@ -91,6 +92,8 @@ public class JsonStreamFeeder { private static final JsonFactory factory = new JsonFactory(); + @Override public void close() throws IOException { client.close(); } + private class RingBufferStream extends InputStream { private final byte[] b = new byte[1]; |