made canTakeMoreData a default method
@@ -70,7 +70,9 @@ public interface WireOutPublisher extends Closeable {
throw new UnsupportedOperationException();
}
- boolean canTakeMoreData();
+ default boolean canTakeMoreData() {
+ return false;
+ }
/**
* @param key the key to the event, only used when throttling, otherwise NULL if the
