Skip to content

Commit c6d117f

Browse files
committed
feat(batch): updata batch.proto and adjust code
1 parent 60c41ba commit c6d117f

4 files changed

Lines changed: 241 additions & 777 deletions

File tree

src/main/java/io/weaviate/client6/v1/api/collections/batch/TranslatingStreamFactory.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -97,12 +97,8 @@ public void onNext(BatchStreamReply reply) {
9797
case SHUTTING_DOWN:
9898
event = Event.SHUTTING_DOWN;
9999
break;
100-
case SHUTDOWN:
101-
event = Event.EOF;
102-
break;
103100
case OUT_OF_MEMORY:
104-
// TODO(dyma): read this value from the message
105-
event = new Event.Oom(300);
101+
event = new Event.Oom(reply.getOutOfMemory().getWaitTime());
106102
break;
107103
case BACKOFF:
108104
event = new Event.Backoff(reply.getBackoff().getBatchSize());

0 commit comments

Comments
 (0)