Class LoggingConsumer
java.lang.Object
rx.Subscriber<CouchbaseEvent>
com.couchbase.client.core.event.consumers.LoggingConsumer
- All Implemented Interfaces:
rx.Observer<CouchbaseEvent>
,rx.Subscription
public class LoggingConsumer extends rx.Subscriber<CouchbaseEvent>
Consumes
CouchbaseEvent
s and logs them.- Since:
- 1.2.0
- Author:
- Michael Nitschinger
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
LoggingConsumer.OutputFormat
The target output format to log. -
Field Summary
Fields Modifier and Type Field Description static LoggingConsumer.OutputFormat
DEFAULT_FORMAT
-
Method Summary
Modifier and Type Method Description static LoggingConsumer
create()
static LoggingConsumer
create(CouchbaseLogLevel level, LoggingConsumer.OutputFormat outputFormat)
void
onCompleted()
void
onError(Throwable ex)
void
onNext(CouchbaseEvent event)
Methods inherited from class rx.Subscriber
add, isUnsubscribed, onStart, request, setProducer, unsubscribe
-
Field Details
-
DEFAULT_FORMAT
-
-
Method Details
-
create
-
create
public static LoggingConsumer create(CouchbaseLogLevel level, LoggingConsumer.OutputFormat outputFormat) -
onCompleted
public void onCompleted() -
onError
-
onNext
-