Class OperatorOnBackpressureBuffer<T>

    • Constructor Detail

      • OperatorOnBackpressureBuffer

        OperatorOnBackpressureBuffer()
      • OperatorOnBackpressureBuffer

        public OperatorOnBackpressureBuffer​(long capacity)
        Construct a new instance that will handle overflows with ON_OVERFLOW_DEFAULT, providing the following behavior config:
        Parameters:
        capacity - the max number of items to be admitted in the buffer, must be greater than 0.
      • OperatorOnBackpressureBuffer

        public OperatorOnBackpressureBuffer​(long capacity,
                                            Action0 onOverflow)
        Construct a new instance that will handle overflows with ON_OVERFLOW_DEFAULT, providing the following behavior config:
        Parameters:
        capacity - the max number of items to be admitted in the buffer, must be greater than 0.
        onOverflow - the Action0 to execute when the buffer overflows, may be null.
      • OperatorOnBackpressureBuffer

        public OperatorOnBackpressureBuffer​(long capacity,
                                            Action0 onOverflow,
                                            BackpressureOverflow.Strategy overflowStrategy)
        Construct a new instance feeding the following behavior config:
        Parameters:
        capacity - the max number of items to be admitted in the buffer, must be greater than 0.
        onOverflow - the Action0 to execute when the buffer overflows, may be null.
        overflowStrategy - the BackpressureOverflow.Strategy to handle overflows, it must not be null.