public final class CoalescingWrites extends Object implements CommandHandler
| Modifier and Type | Field and Description |
|---|---|
static StreamTransformer |
TRANSFORMER |
| Modifier and Type | Method and Description |
|---|---|
void |
onDone()
This method is called when the stream has been closed.
|
void |
onEmit(Command command)
Allows this handler to process the
Command that was just written into the stream to which this handler was attached. |
void |
onError(String errorMessage)
Allows this handler to process error states.
|
public static final StreamTransformer TRANSFORMER
public void onEmit(Command command)
CommandHandlerCommand that was just written into the stream to which this handler was attached.onEmit in interface CommandHandlercommand - the received commandpublic void onError(String errorMessage)
CommandHandleronError in interface CommandHandlererrorMessage - the error's messagepublic void onDone()
CommandHandleronDone in interface CommandHandlerCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.