Package | Description |
---|---|
com.couchbase.client.core.utils |
Modifier and Type | Method and Description |
---|---|
static <T> UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.create(long noSubscriptionTimeout,
TimeUnit timeUnit) |
static <T> UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.create(long noSubscriptionTimeout,
TimeUnit timeUnit,
rx.functions.Action0 onUnsubscribe) |
static <T> UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.create(long noSubscriptionTimeout,
TimeUnit timeUnit,
rx.Scheduler timeoutScheduler) |
static <T> UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.create(long noSubscriptionTimeout,
TimeUnit timeUnit,
rx.Scheduler timeoutScheduler,
rx.functions.Action0 onUnsubscribe) |
static <T> UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.createWithoutNoSubscriptionTimeout()
Creates a new
UnicastAutoReleaseSubject without a no subscription timeout. |
static <T> UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.createWithoutNoSubscriptionTimeout(rx.functions.Action0 onUnsubscribe)
Creates a new
UnicastAutoReleaseSubject without a no subscription timeout. |
UnicastAutoReleaseSubject<T> |
UnicastAutoReleaseSubject.withTraceIdentifier(String id) |
Copyright © 2021 Couchbase, Inc.. All rights reserved.