You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by pv...@apache.org on 2020/03/31 07:47:13 UTC
[nifi] branch master updated: NIFI-7297 add available()
This is an automated email from the ASF dual-hosted git repository.
pvillard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/master by this push:
new f4a7aaf NIFI-7297 add available()
f4a7aaf is described below
commit f4a7aafe4a243e6eea43781ce0a3bd3f42714617
Author: KovalevIV <El...@yandex.ru>
AuthorDate: Mon Mar 30 23:30:10 2020 +0300
NIFI-7297 add available()
Signed-off-by: Pierre Villard <pi...@gmail.com>
This closes #4172.
---
nifi-mock/src/main/java/org/apache/nifi/util/MockProcessSession.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/nifi-mock/src/main/java/org/apache/nifi/util/MockProcessSession.java b/nifi-mock/src/main/java/org/apache/nifi/util/MockProcessSession.java
index 7bf9a03..fe9faf9 100644
--- a/nifi-mock/src/main/java/org/apache/nifi/util/MockProcessSession.java
+++ b/nifi-mock/src/main/java/org/apache/nifi/util/MockProcessSession.java
@@ -619,6 +619,11 @@ public class MockProcessSession implements ProcessSession {
}
@Override
+ public int available() throws IOException {
+ return bais.available();
+ }
+
+ @Override
public String toString() {
return "ErrorHandlingInputStream[flowFile=" + mock + "]";
}