public interface Consumer<T>
Modifier and Type | Method and Description |
---|---|
void |
consumeData(T data)
Some data has been produced.
|
void |
setDone()
No more data will be produced; done.
|
void |
setError(Throwable t)
No more data will be produced; error during production.
|
void consumeData(T data) throws InterruptedException
InterruptedException
void setDone() throws InterruptedException
InterruptedException
void setError(Throwable t) throws InterruptedException
InterruptedException
Copyright © 2022 The Apache Software Foundation. All rights reserved.