Record Class ObservableConcatConfig
java.lang.Object
java.lang.Record
io.reactivex.rxjava4.core.config.ObservableConcatConfig
- Record Components:
errorMode- how to handle when errors appear from the inner or outer sourcesbufferSize- the expected number of outer sources to buffer while processing an inner source
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final ObservableConcatConfigThe default configuration with no error delays and bufferSize ofObservable.bufferSize().static final ObservableConcatConfigThe default configuration with error delays till the end and bufferSize ofObservable.bufferSize().static final ObservableConcatConfigThe default configuration with error delays till the boundary and bufferSize ofObservable.bufferSize(). -
Constructor Summary
ConstructorsConstructorDescriptionObservableConcatConfig(int bufferSize) Constructs a configuration record.ObservableConcatConfig(@NonNull ErrorMode errorMode) Constructs a configuration record.ObservableConcatConfig(@NonNull ErrorMode errorMode, int bufferSize) Constructs a configuration record. -
Method Summary
Modifier and TypeMethodDescriptionintReturns the value of thebufferSizerecord component.final booleanIndicates whether some other object is "equal to" this one.Returns the value of theerrorModerecord component.final inthashCode()Returns a hash code value for this object.final StringtoString()Returns a string representation of this record class.
-
Field Details
-
DEFAULT
The default configuration with no error delays and bufferSize ofObservable.bufferSize(). -
DELAY_ERROR
The default configuration with error delays till the end and bufferSize ofObservable.bufferSize(). -
DELAY_ERROR_BOUNDARY
The default configuration with error delays till the boundary and bufferSize ofObservable.bufferSize().
-
-
Constructor Details
-
ObservableConcatConfig
-
ObservableConcatConfig
public ObservableConcatConfig(int bufferSize) Constructs a configuration record.- Parameters:
bufferSize- the expected number of outer sources to buffer while processing an inner source
-
ObservableConcatConfig
Constructs a configuration record.- Parameters:
errorMode- how to handle when errors appear from the inner or outer sourcesbufferSize- the expected number of outer sources to buffer while processing an inner source
-
-
Method Details
-
toString
-
hashCode
-
equals
Indicates whether some other object is "equal to" this one. The objects are equal if the other object is of the same class and if all the record components are equal. Reference components are compared withObjects::equals(Object,Object); primitive components are compared with thecomparemethod from their corresponding wrapper classes. -
errorMode
-
bufferSize
public int bufferSize()Returns the value of thebufferSizerecord component.- Returns:
- the value of the
bufferSizerecord component
-