Package org.redisson.api

Interface RBitSetRx

All Superinterfaces:
RExpirableRx, RObjectRx
public interface RBitSetRx extends RExpirableRx
RxJava2 interface for BitSet object
Author:
Nikita Koksharov

  • Method Summary

    Modifier and Type
    Method
    Description
    io.reactivex.rxjava3.core.Single<Long>
    and(String... bitSetNames)
    Executes AND operation over this object and specified bitsets.
    io.reactivex.rxjava3.core.Single<Long>
    andOr(String... bitSetNames)
    Executes bitwise ANDOR operation over this object and specified bitsets.
    io.reactivex.rxjava3.core.Single<Long>
    cardinality()
    Returns the number of bits set to one.
    io.reactivex.rxjava3.core.Completable
    clear()
    Set all bits to zero
    io.reactivex.rxjava3.core.Single<Boolean>
    clear(long bitIndex)
    Set bit to zero at specified bitIndex
    io.reactivex.rxjava3.core.Completable
    clear(long fromIndex, long toIndex)
    Set all bits to zero from fromIndex (inclusive) to toIndex (exclusive)
    io.reactivex.rxjava3.core.Single<Long>
    diff(String... bitSetNames)
    Executes bitwise DIFF operation over this object and specified bitsets.
    io.reactivex.rxjava3.core.Single<Long>
    diffInverse(String... bitSetNames)
    Executes bitwise DIFF1 operation over this object and specified bitsets.
    io.reactivex.rxjava3.core.Single<Boolean>
    get(long bitIndex)
    Returns true if bit set to one and false overwise.
    io.reactivex.rxjava3.core.Single<boolean[]>
    get(long... bitIndexes)
    Returns a boolean array where each element of the array corresponds to the query result of the input parameters.
    io.reactivex.rxjava3.core.Single<Byte>
    getByte(long offset)
    Returns byte number at specified offset
    io.reactivex.rxjava3.core.Single<Integer>
    getInteger(long offset)
    Returns integer number at specified offset
    io.reactivex.rxjava3.core.Single<Long>
    getLong(long offset)
    Returns long number at specified offset
    io.reactivex.rxjava3.core.Single<Short>
    getShort(long offset)
    Returns short number at specified offset
    io.reactivex.rxjava3.core.Single<Long>
    getSigned(int size, long offset)
    Returns signed number at specified offset and size
    io.reactivex.rxjava3.core.Single<Long>
    getUnsigned(int size, long offset)
    Returns unsigned number at specified offset and size
    io.reactivex.rxjava3.core.Single<Byte>
    incrementAndGetByte(long offset, byte increment)
    Increments current byte value on defined increment value at specified offset and returns result.
    io.reactivex.rxjava3.core.Single<Integer>
    incrementAndGetInteger(long offset, int increment)
    Increments current integer value on defined increment value at specified offset and returns result.
    io.reactivex.rxjava3.core.Single<Long>
    incrementAndGetLong(long offset, long increment)
    Increments current long value on defined increment value at specified offset and returns result.
    io.reactivex.rxjava3.core.Single<Short>
    incrementAndGetShort(long offset, short increment)
    Increments current short value on defined increment value at specified offset and returns result.
    io.reactivex.rxjava3.core.Single<Long>
    incrementAndGetSigned(int size, long offset, long increment)
    Increments current signed value by defined increment value and size at specified offset and returns result.
    io.reactivex.rxjava3.core.Single<Long>
    incrementAndGetUnsigned(int size, long offset, long increment)
    Increments current unsigned value by defined increment value and size at specified offset and returns result.
    io.reactivex.rxjava3.core.Single<Long>
    length()
    Returns "logical size" = index of highest set bit plus one.
    io.reactivex.rxjava3.core.Single<Long>
    not()
    Executes NOT operation over all bits
    io.reactivex.rxjava3.core.Single<Long>
    or(String... bitSetNames)
    Executes OR operation over this object and specified bitsets.
    io.reactivex.rxjava3.core.Single<Boolean>
    set(long bitIndex)
    Set bit to one at specified bitIndex
    io.reactivex.rxjava3.core.Single<Boolean>
    set(long bitIndex, boolean value)
    Set bit to value at specified bitIndex
    io.reactivex.rxjava3.core.Completable
    set(long fromIndex, long toIndex)
    Set all bits to one from fromIndex (inclusive) to toIndex (exclusive)
    io.reactivex.rxjava3.core.Completable
    set(long fromIndex, long toIndex, boolean value)
    Set all bits to value from fromIndex (inclusive) to toIndex (exclusive)
    io.reactivex.rxjava3.core.Completable
    set(BitSet bs)
    Copy bits state of source BitSet object to this object
    io.reactivex.rxjava3.core.Single<Byte>
    setByte(long offset, byte value)
    Returns previous value of byte number and replaces it with defined value at specified offset
    io.reactivex.rxjava3.core.Single<Long>
    setExclusive(String... bitSetNames)
    Executes bitwise ONE operation over this object and specified bitsets.
    io.reactivex.rxjava3.core.Single<Integer>
    setInteger(long offset, int value)
    Returns previous value of integer number and replaces it with defined value at specified offset
    io.reactivex.rxjava3.core.Single<Long>
    setLong(long offset, long value)
    Returns previous value of long number and replaces it with defined value at specified offset
    io.reactivex.rxjava3.core.Single<Short>
    setShort(long offset, short value)
    Returns previous value of short number and replaces it with defined value at specified offset
    io.reactivex.rxjava3.core.Single<Long>
    setSigned(int size, long offset, long value)
    Returns previous value of signed number and replaces it with defined value at specified offset
    io.reactivex.rxjava3.core.Single<Long>
    setUnsigned(int size, long offset, long value)
    Returns previous value of unsigned number and replaces it with defined value at specified offset
    io.reactivex.rxjava3.core.Single<Long>
    size()
    Returns number of set bits.
    io.reactivex.rxjava3.core.Single<byte[]>
    toByteArray()
     
    io.reactivex.rxjava3.core.Single<Long>
    xor(String... bitSetNames)
    Executes XOR operation over this object and specified bitsets.

    Methods inherited from interface org.redisson.api.RExpirableRx

    clearExpire, expire, expire, expire, expireAt, expireAt, expireIfGreater, expireIfGreater, expireIfLess, expireIfLess, expireIfNotSet, expireIfNotSet, expireIfSet, expireIfSet, getExpireTime, remainTimeToLive

    Methods inherited from interface org.redisson.api.RObjectRx

    addListener, copy, copy, copy, copyAndReplace, copyAndReplace, delete, dump, getAccessFrequency, getCodec, getIdleTime, getInternalEncoding, getName, getReferenceCount, isExists, migrate, move, removeListener, rename, renamenx, restore, restore, restoreAndReplace, restoreAndReplace, sizeInMemory, touch, unlink

  • Method Details

    • getSigned

      io.reactivex.rxjava3.core.Single<Long> getSigned(int size, long offset)
      Returns signed number at specified offset and size
      Parameters:
      size - - size of signed number up to 64 bits
      offset - - offset of signed number
      Returns:
      signed number

    • setSigned

      io.reactivex.rxjava3.core.Single<Long> setSigned(int size, long offset, long value)
      Returns previous value of signed number and replaces it with defined value at specified offset
      Parameters:
      size - - size of signed number up to 64 bits
      offset - - offset of signed number
      value - - value of signed number
      Returns:
      previous value of signed number

    • incrementAndGetSigned

      io.reactivex.rxjava3.core.Single<Long> incrementAndGetSigned(int size, long offset, long increment)
      Increments current signed value by defined increment value and size at specified offset and returns result.
      Parameters:
      size - - size of signed number up to 64 bits
      offset - - offset of signed number
      increment - - increment value
      Returns:
      result value

    • getUnsigned

      io.reactivex.rxjava3.core.Single<Long> getUnsigned(int size, long offset)
      Returns unsigned number at specified offset and size
      Parameters:
      size - - size of unsigned number up to 64 bits
      offset - - offset of unsigned number
      Returns:
      unsigned number

    • setUnsigned

      io.reactivex.rxjava3.core.Single<Long> setUnsigned(int size, long offset, long value)
      Returns previous value of unsigned number and replaces it with defined value at specified offset
      Parameters:
      size - - size of unsigned number up to 64 bits
      offset - - offset of unsigned number
      value - - value of unsigned number
      Returns:
      previous value of unsigned number

    • incrementAndGetUnsigned

      io.reactivex.rxjava3.core.Single<Long> incrementAndGetUnsigned(int size, long offset, long increment)
      Increments current unsigned value by defined increment value and size at specified offset and returns result.
      Parameters:
      size - - size of unsigned number up to 64 bits
      offset - - offset of unsigned number
      increment - - increment value
      Returns:
      result value

    • getByte

      io.reactivex.rxjava3.core.Single<Byte> getByte(long offset)
      Returns byte number at specified offset
      Parameters:
      offset - - offset of number
      Returns:
      number

    • setByte

      io.reactivex.rxjava3.core.Single<Byte> setByte(long offset, byte value)
      Returns previous value of byte number and replaces it with defined value at specified offset
      Parameters:
      offset - - offset of number
      value - - value of number
      Returns:
      previous value of number

    • incrementAndGetByte

      io.reactivex.rxjava3.core.Single<Byte> incrementAndGetByte(long offset, byte increment)
      Increments current byte value on defined increment value at specified offset and returns result.
      Parameters:
      offset - - offset of number
      increment - - increment value
      Returns:
      result value

    • getShort

      io.reactivex.rxjava3.core.Single<Short> getShort(long offset)
      Returns short number at specified offset
      Parameters:
      offset - - offset of number
      Returns:
      number

    • setShort

      io.reactivex.rxjava3.core.Single<Short> setShort(long offset, short value)
      Returns previous value of short number and replaces it with defined value at specified offset
      Parameters:
      offset - - offset of number
      value - - value of number
      Returns:
      previous value of number

    • incrementAndGetShort

      io.reactivex.rxjava3.core.Single<Short> incrementAndGetShort(long offset, short increment)
      Increments current short value on defined increment value at specified offset and returns result.
      Parameters:
      offset - - offset of number
      increment - - increment value
      Returns:
      result value

    • getInteger

      io.reactivex.rxjava3.core.Single<Integer> getInteger(long offset)
      Returns integer number at specified offset
      Parameters:
      offset - - offset of number
      Returns:
      number

    • setInteger

      io.reactivex.rxjava3.core.Single<Integer> setInteger(long offset, int value)
      Returns previous value of integer number and replaces it with defined value at specified offset
      Parameters:
      offset - - offset of number
      value - - value of number
      Returns:
      previous value of number

    • incrementAndGetInteger

      io.reactivex.rxjava3.core.Single<Integer> incrementAndGetInteger(long offset, int increment)
      Increments current integer value on defined increment value at specified offset and returns result.
      Parameters:
      offset - - offset of number
      increment - - increment value
      Returns:
      result value

    • getLong

      io.reactivex.rxjava3.core.Single<Long> getLong(long offset)
      Returns long number at specified offset
      Parameters:
      offset - - offset of number
      Returns:
      number

    • setLong

      io.reactivex.rxjava3.core.Single<Long> setLong(long offset, long value)
      Returns previous value of long number and replaces it with defined value at specified offset
      Parameters:
      offset - - offset of number
      value - - value of number
      Returns:
      previous value of number

    • incrementAndGetLong

      io.reactivex.rxjava3.core.Single<Long> incrementAndGetLong(long offset, long increment)
      Increments current long value on defined increment value at specified offset and returns result.
      Parameters:
      offset - - offset of number
      increment - - increment value
      Returns:
      result value

    • toByteArray

      io.reactivex.rxjava3.core.Single<byte[]> toByteArray()

    • length

      io.reactivex.rxjava3.core.Single<Long> length()
      Returns "logical size" = index of highest set bit plus one. Returns zero if there are no any set bit.
      Returns:
      "logical size" = index of highest set bit plus one

    • set

      io.reactivex.rxjava3.core.Completable set(long fromIndex, long toIndex, boolean value)
      Set all bits to value from fromIndex (inclusive) to toIndex (exclusive)
      Parameters:
      fromIndex - inclusive
      toIndex - exclusive
      value - true = 1, false = 0
      Returns:
      void

    • clear

      io.reactivex.rxjava3.core.Completable clear(long fromIndex, long toIndex)
      Set all bits to zero from fromIndex (inclusive) to toIndex (exclusive)
      Parameters:
      fromIndex - inclusive
      toIndex - exclusive
      Returns:
      void

    • set

      io.reactivex.rxjava3.core.Completable set(BitSet bs)
      Copy bits state of source BitSet object to this object
      Parameters:
      bs - - BitSet source
      Returns:
      void

    • not

      io.reactivex.rxjava3.core.Single<Long> not()
      Executes NOT operation over all bits
      Returns:
      length in bytes of the destination key

    • set

      io.reactivex.rxjava3.core.Completable set(long fromIndex, long toIndex)
      Set all bits to one from fromIndex (inclusive) to toIndex (exclusive)
      Parameters:
      fromIndex - inclusive
      toIndex - exclusive
      Returns:
      void

    • size

      io.reactivex.rxjava3.core.Single<Long> size()
      Returns number of set bits.
      Returns:
      number of set bits.

    • get

      io.reactivex.rxjava3.core.Single<Boolean> get(long bitIndex)
      Returns true if bit set to one and false overwise.
      Parameters:
      bitIndex - - index of bit
      Returns:
      true if bit set to one and false overwise.

    • get

      io.reactivex.rxjava3.core.Single<boolean[]> get(long... bitIndexes)
      Returns a boolean array where each element of the array corresponds to the query result of the input parameters.
      Parameters:
      bitIndexes - indexes of bit
      Returns:
      Returns a boolean array where each element of the array corresponds to the query result of the input parameters.

    • set

      io.reactivex.rxjava3.core.Single<Boolean> set(long bitIndex)
      Set bit to one at specified bitIndex
      Parameters:
      bitIndex - - index of bit
      Returns:
      true - if previous value was true, false - if previous value was false

    • set

      io.reactivex.rxjava3.core.Single<Boolean> set(long bitIndex, boolean value)
      Set bit to value at specified bitIndex
      Parameters:
      bitIndex - - index of bit
      value - true = 1, false = 0
      Returns:
      true - if previous value was true, false - if previous value was false

    • cardinality

      io.reactivex.rxjava3.core.Single<Long> cardinality()
      Returns the number of bits set to one.
      Returns:
      number of bits

    • clear

      io.reactivex.rxjava3.core.Single<Boolean> clear(long bitIndex)
      Set bit to zero at specified bitIndex
      Parameters:
      bitIndex - - index of bit
      Returns:
      true - if previous value was true, false - if previous value was false

    • clear

      io.reactivex.rxjava3.core.Completable clear()
      Set all bits to zero
      Returns:
      void

    • or

      io.reactivex.rxjava3.core.Single<Long> or(String... bitSetNames)
      Executes OR operation over this object and specified bitsets. Stores result into this object.
      Parameters:
      bitSetNames - - name of stored bitsets
      Returns:
      length in bytes of the destination key

    • and

      io.reactivex.rxjava3.core.Single<Long> and(String... bitSetNames)
      Executes AND operation over this object and specified bitsets. Stores result into this object.
      Parameters:
      bitSetNames - - name of stored bitsets
      Returns:
      length in bytes of the destination key

    • xor

      io.reactivex.rxjava3.core.Single<Long> xor(String... bitSetNames)
      Executes XOR operation over this object and specified bitsets. Stores result into this object.
      Parameters:
      bitSetNames - - name of stored bitsets
      Returns:
      length in bytes of the destination key

    • diff

      io.reactivex.rxjava3.core.Single<Long> diff(String... bitSetNames)
      Executes bitwise DIFF operation over this object and specified bitsets. Sets bits that are set in this object but not in any of the other bitsets. Stores result into this object.
      Parameters:
      bitSetNames - name of stored bitsets
      Returns:
      length in bytes of the destination key

    • diffInverse

      io.reactivex.rxjava3.core.Single<Long> diffInverse(String... bitSetNames)
      Executes bitwise DIFF1 operation over this object and specified bitsets. Sets bits that are set in one or more of the other bitsets but not in this object. Stores result into this object.
      Parameters:
      bitSetNames - name of stored bitsets
      Returns:
      length in bytes of the destination key

    • andOr

      io.reactivex.rxjava3.core.Single<Long> andOr(String... bitSetNames)
      Executes bitwise ANDOR operation over this object and specified bitsets. Sets bits that are set in this object AND also in one or more of the other bitsets. Stores result into this object.
      Parameters:
      bitSetNames - name of stored bitsets
      Returns:
      length in bytes of the destination key

    • setExclusive

      io.reactivex.rxjava3.core.Single<Long> setExclusive(String... bitSetNames)
      Executes bitwise ONE operation over this object and specified bitsets. Sets bits that are set in exactly one of the provided bitsets. Stores result into this object.
      Parameters:
      bitSetNames - name of stored bitsets
      Returns:
      length in bytes of the destination key