public class PublisherResponse extends Object
Constructor and Description |
---|
PublisherResponse(Object[] results,
IntSet completedSegments,
IntSet lostSegments,
int size,
boolean complete,
int segmentOffset) |
Modifier and Type | Method and Description |
---|---|
static PublisherResponse |
emptyResponse(IntSet completedSegments,
IntSet lostSegments) |
void |
forEachSegmentValue(ObjIntConsumer consumer,
int segment) |
IntSet |
getCompletedSegments() |
IntSet |
getLostSegments() |
Object[] |
getResults() |
int |
getSize() |
boolean |
isComplete() |
String |
toString() |
public static PublisherResponse emptyResponse(IntSet completedSegments, IntSet lostSegments)
public Object[] getResults()
public IntSet getCompletedSegments()
public IntSet getLostSegments()
public int getSize()
public boolean isComplete()
public void forEachSegmentValue(ObjIntConsumer consumer, int segment)
Copyright © 2021 JBoss by Red Hat. All rights reserved.