blocking subscriber #onnext object call with an infinite wait on backpressure . concode_field_sep Subscriber<? super E> actual concode_elem_sep long requested concode_elem_sep Predicate NEVER concode_elem_sep boolean cancelled concode_elem_sep Throwable uncaughtException concode_elem_sep AtomicLongFieldUpdater<BlockingSink> REQUESTED concode_field_sep void cancel concode_elem_sep void next concode_elem_sep boolean isBackpressured concode_elem_sep void request concode_elem_sep boolean isCancelled concode_elem_sep boolean isCancelled concode_elem_sep boolean isFailed concode_elem_sep Subscriber<? super E> downstream concode_elem_sep void start concode_elem_sep boolean hasRequested concode_elem_sep long requestedFromDownstream concode_elem_sep void error concode_elem_sep void accept concode_elem_sep Throwable getError concode_elem_sep boolean hasFailed concode_elem_sep void stop concode_elem_sep boolean isOk concode_elem_sep BlockingSink<E> create concode_elem_sep BlockingSink<E> create concode_elem_sep Emission finish concode_elem_sep String toString concode_elem_sep Emission emit concode_elem_sep void complete concode_elem_sep void close concode_elem_sep long getCapacity
long function ( E arg0 ) { return submit ( arg0 , - 1L , TimeUnit . MILLISECONDS , NEVER ) ; }