public final class Consumers extends Object
Modifier and Type | Method and Description |
---|---|
static io.reactivex.functions.LongConsumer |
addLongTo(List<Long> list) |
static <T> io.reactivex.functions.Consumer<T> |
addTo(List<T> list) |
static io.reactivex.functions.Consumer<byte[]> |
assertBytesEquals(byte[] expected) |
static <T extends Closeable> |
close() |
static io.reactivex.functions.Consumer<Object> |
decrement(AtomicInteger value) |
static <T> io.reactivex.functions.Consumer<T> |
doNothing() |
static io.reactivex.functions.Consumer<Object> |
increment(AtomicInteger value) |
static <T> io.reactivex.functions.Consumer<T> |
println() |
static io.reactivex.functions.LongConsumer |
printLong(String prefix) |
static io.reactivex.functions.Consumer<Throwable> |
printStackTrace() |
static io.reactivex.functions.Consumer<Integer> |
set(AtomicInteger value) |
static <T> io.reactivex.functions.Consumer<T> |
set(AtomicReference<T> value) |
static <T> io.reactivex.functions.Consumer<T> |
setToTrue(AtomicBoolean value) |
public static <T extends Closeable> io.reactivex.functions.Consumer<T> close()
public static io.reactivex.functions.Consumer<Object> increment(AtomicInteger value)
public static io.reactivex.functions.Consumer<Throwable> printStackTrace()
public static <T> io.reactivex.functions.Consumer<T> doNothing()
public static <T> io.reactivex.functions.Consumer<T> set(AtomicReference<T> value)
public static io.reactivex.functions.Consumer<Integer> set(AtomicInteger value)
public static io.reactivex.functions.Consumer<Object> decrement(AtomicInteger value)
public static <T> io.reactivex.functions.Consumer<T> setToTrue(AtomicBoolean value)
public static <T> io.reactivex.functions.Consumer<T> addTo(List<T> list)
public static <T> io.reactivex.functions.Consumer<T> println()
public static io.reactivex.functions.Consumer<byte[]> assertBytesEquals(byte[] expected)
public static io.reactivex.functions.LongConsumer printLong(String prefix)
Copyright © 2013–2020. All rights reserved.